Scalaz

Or: How I learned to stop worrying and love monads

Scala.io - 24 October 2014

Noel Markham - @noelmarkham

Hello :-)


Schedule

  • Enhancements out of the box
  • A better either
  • Typeclass definition
  • Various Scalaz typeclasses
  • Monads

libraryDependencies += "org.scalaz" %% "scalaz-core" % "7.1.0" 
          

import scalaz._
import Scalaz._
          

Enhancements out of the box

Booleans

.option


scala> val boolT = 6 < 10
boolT: Boolean = true

scala> val boolF = 6 > 10
boolF: Boolean = false

scala> boolT.option("vrai")
res0: Option[String] = Some(vrai)

scala> boolF.option("vrai")
res1: Option[String] = None
	  

Neater than:


scala> if(boolT) Some("vrai") else None
res2: Option[String] = Some(vrai)
	  

Enhancements out of the box

Strings

.parseXXX


scala> "6".parseInt
res3: scalaz.Validation[NumberFormatException,Int] = Success(6)

scala> "rosbif".parseBoolean
res4: scalaz.Validation[IllegalArgumentException,Boolean] =
      Failure(java.lang.IllegalArgumentException: For input string: "rosbif")
          

Enhancements out of the box

Lists

.allPairs


scala> List(1, 2, 3, 4).allPairs
res6: List[(Int, Int)] = List((1,2), (2,3), (3,4), (1,3), (2,4), (1,4))
          

.powerset


scala> List('a', 'b', 'c').powerset.foreach(println)
List(a, b, c)
List(a, b)
List(a, c)
List(a)
List(b, c)
List(b)
List(c)
List()
          

Enhancements out of the box

All types

.some


scala> "rosbif".some
res6: Option[String] = Some(rosbif)
          

scala> Some("rosbif")
res7: Some[String] = Some(rosbif)
          

scala> Some(1) |+| Some(2)
<console>:14: error: value |+| is not a member of Some[Int]
              Some(1) |+| Some(2)
          

scala> 1.some |+| 2.some
res12: Option[Int] = Some(3)
          

scala> case class Money(currency: String, amount: Int)
defined class Money

scala> Money("EUR", 3).some
res3: Option[Money] = Some(Money(EUR, 3))
          

Enhancements out of the box

There are plenty more.

A Better Either

Scala: Either[A, B]

Scalaz: \/[A, B]


Infix notation: A \/ B

Exception \/ HttpResponse

ApplicationError \/ String

A Better Either


scala> val result = Right(6)
result: scala.util.Right[Nothing,Int] = Right(6)

scala> result.right.map(_ + 4)
res30: Either[Nothing,Int] = Right(10)

          

scala> val more = \/-(6)
more: scalaz.\/-[Int] = \/-(6)

scala> more.map(_ + 4)
res31: scalaz.\/[Nothing,Int] = \/-(10)
          

A Better Either

“Can we give it a plain text name rather than that strange symbol?”

“It's just a mathematical symbol like plus.”

“Use it for a week and we can discuss it after that.”


type Result[+A] = ApplicationError \/ A

Typeclasses

A simple example

(This example lifted from Martin Odersky's paper: Type Classes as Objects and Implicits)

Typeclasses

A simple example

A trait for defining order:


trait Ord[T] {
  def compare(a: T, b: T): Boolean
}
        

An Ord instance for a specific type:


object intOrd extends Ord[Int] {
  def compare(a: Int, b: Int): Boolean = a <= b
}
        

This instance can be used when necessary:


def sort[T](xs: List[T])(ord: Ord[T]): List[T] = ...
          

scala> sort(List(3, 2, 1))(intOrd)
res5: List[Int] = List(1, 2, 3)
          

Typeclasses

A simple example

implicit object intOrd extends Ord[Int] ... // as before
          

def sort[T](xs: List[T])(implicit ord: Ord[T]): List[T] = ... // as before
          

scala> sort[Int](List(4, 3, 6, 1, 7))
res4: List(1, 3, 4, 6, 7)
          

No implicit in scope:


scala> sort[String](List("z", "y", "x", "w"))
<console>:28: error: 
            could not find implicit value for parameter ord: Ord[String]
          

Typeclasses

Daunted? Confused?

public interface Comparator<T> {
    int compare(T o1, T o2);
}
          

Collections.sort:


public static <T> void sort(List<T> list, Comparator<? super T> c)
          

Typeclasses

Within Scalaz:

  • Order
  • Equal
  • Functor
  • Monoid
  • Monad
  • ...

Typeclasses

Equal

scala> "Hello" === "olleH".reverse
res13: Boolean = true
          

scala> "six" === 6
          

<console>:20: error: type mismatch;
 found   : Int(6)
 required: String
              "six" === 6
                        ^
          

Typeclasses

Equal

class Money(val ccy: String, val amount: Int)
          

implicit val equalMoney: Equal[Money] = new Equal[Money] {
  override def equal(m1: Money, m2: Money): Boolean = {
    m1.ccy === m2.ccy && m2.amount === m2.amount
  }
}
          

new Money("GBP", 3) === new Money("EUR", 3)
          

Typeclasses

Equal

case class Money(ccy: String, amount: Int)
          

implicit val equalMoney: Equal[Money] = Equal.equalA[Money]
          

Typeclasses

Functor

A Functor is something that can be mapped


scala> List(10, 20, 30).map(_ / 10)
res13: List[Int] = List(1, 2, 3)
          

scala> "hello".some.map(_.length)
res14: Option[Int] = Some(5)
          

scala> val f = Future(200).map(_ === 404)

scala> f.foreach(println)
false
          

Typeclasses

Functor

def addInt[F[_]](i: Int, toAdd: F[Int])(implicit f: Functor[F]): F[Int] = {
  f.map(toAdd)(_ + i)
}
          

scala> addInt(6, 10.some)
res1: Option[Int] = Some(16)
          

scala> addInt(2, List(10, 11, 12, 13))
res2: List[Int] = List(12, 13, 14, 15)
          

scala> val f = addInt(100, Future(1))

scala> f.foreach(println)
101
          

Typeclasses

Applicative

scala> def sum(a: Int, b: Int, c: Int): Int = a + b + c

scala> val numbers = Map("a" -> 4, "b" -> 5, "c" -> 6)
          

scala> val maybeA = numbers.get("a")
maybeA: Option[Int] = Some(4)

scala> val maybeB = numbers.get("b")
maybeB: Option[Int] = Some(5)

scala> val maybeC = numbers.get("c")
maybeC: Option[Int] = Some(6)
          

scala> val maybeTotal = (maybeA |@| maybeB |@| maybeC)(sum)
maybeTotal: Option[Int] = Some(15)
          

Typeclasses

Applicative

scala> val maybeD = numbers.get("d")
maybeD: Option[Int] = None

scala> val newTotal = (maybeB |@| maybeC |@| maybeD)(sum)
newTotal: Option[Int] = None
          

Think of this as map for a function with an arbitrary number of arguments

Of course, any Applicative, not just Option

Typeclasses

Monoid

trait Semigroup[F] {
  def append(f1: F, f2: => F): F

  def |+|(f1: F, f2: => F): F = append(f1, f2)
}
          

trait Monoid[F] extends Semigroup[F] {
  def zero: F
}
          

A Monoid is a structure with an associative binary operation and an identity element

Typeclasses

Monoid
Associative Binary Operation
a + (b + c) is equal to (a + b) + c

Addition


5 + (6 + 7) === (5 + 6) + 7
          

Multiplication


10 * (2 * 5) === (10 * 2) * 5
          

String concatenation


"abc".concat("def".concat("ghi")) === ("abc".concat("def")).concat("ghi")
          

Typeclasses

Monoid
Identity

Addition: zero


6 + 0 === 6
          

Multiplication: one


6 * 1 === 6
          

String concatenation: empty string


"corrie".concat("") === "corrie"
          

The identity operation for Integer.min?


Integer.min(a, Integer.MAX_VALUE) === a
          

Typeclasses

Monoid

foldMap


scala> List(10, 9, 8).foldMap(i => i)
res20: Int = 27
          

scala> List("alpha", "beta", "gamma").foldMap(s => List(s.length))
res22: List[Int] = List(5, 4, 5)
          

Typeclasses

Monoid

Using append


scala> 1 |+| 2 |+| 3
res23: Int = 6
          

scala> "Hello".some |+| None |+| "World".some
res18: Option[String] = Some(HelloWorld)
          

Typeclasses

Monoid

Using append


scala> val m1 = Map(1 -> List("a", "b"), 2 -> List("aa", "bb"))

scala> val m2 = Map(1 -> List("z"), 3 -> List("yyy", "zzz"))

scala> m1 |+| m2
          

res25: Map(1 -> List(a, b, z), 3 -> List(yyy, zzz), 2 -> List(aa, bb))
          

Typeclasses

Monoid

Using append


scala> val m1 = Map("a" -> 1, "b" -> 1)

scala> val m2 = Map("a" -> 1, "c" -> 1)

scala> m1 |+| m2
          

res30: Map(a -> 2, c -> 1, b -> 1)
          

scala> List("a", "b", "b", "b", "c", "c").foldMap(c => Map(c -> 1))
          

res32: Map(b -> 3, a -> 1, c -> 2)
          

Monads

Typeclasses

Monad

My experience with monads:

  • They're not as confusing as the Internet seems to think.
  • There are plenty of silly analogies on the Internet.
  • The name of for comprehensions is confusing.
  • The List monad is quite a confusing place to start.
  • If you can define your API to be functions A => M[B], most other things slot into place easily.
  • Abstraction over monad types is the killer feature.

A monad encapsulates a specific pattern that occurs frequently

What is a monad?

Examples

Get two values from a map and divide one by the other

Retrieve a value from a map (but it might not be there)


def get(key: A): Option[B]
          

Perform division (but you might try to divide by zero)


def divide(numerator: Int, denominator: Int): Option[Int]
          

What is a monad?

Examples

Get some data from a web page and persist it to a database

Make an HTTP call (eventually)


def httpGet(url: String): Future[String]
          

Store a value in a database (eventually)


def persist(data: String): Future[Unit]
          

What is a monad?

There is a pattern here:


def get(key: A): Option[B]
def divide(numerator: Int, denominator: Int): Option[Int]
          

def httpGet(url: String): Future[String]
def persist(data: String): Future[Unit]
          

The functions all return some type with some extra behaviour

Is this useful? Can we abstract this?

Typeclasses

Monad

trait Monad[M[_]] { self =>
    def point[A](a: => A): M[A]

    def bind[A, B](fa: M[A])(f: (A) => M[B]): M[B]

    def flatMap[B](f: A => M[B]) = bind(self)(f)
    def >>=[B](f: A => M[B]) = bind(self)(f)

    def map[A, B](fa: M[A])(f: A => B) = bind(fa)(a => point(f(a)))
}
          

Typeclasses

Monad

def point[A](a: => A): M[A]

“Given an A, this will give me an M[A].”

Typeclasses

Monad

def bind[A,B](fa: M[A])(f: (A) => M[B]): M[B]

“If I have an M[A],

and a function A => M[B],

then I can use this to get M[B].”

“Chaining” calls

Given:


def getUserId(username: String): Option[Int]
def getUser(id: Int): Option[User]
def getAddress(user: User): Option[Address]
          

You can chain these together using flatMap.


def addressFromUsername(username: String): Option[Address] = 
                 getUserId(username).flatMap(getUser).flatMap(getAddress)
          

getUserId(username) >>= getUser >>= getAddress
          

“Chaining” calls

For comprehensions

def getUserId(username: String): Option[Int]
def getUser(id: Int): Option[User]
def getAddress(user: User): Option[Address]
          

for {
  userId  <- getUserId(username)
  user    <- getUser(userId)
  address <- getAddress(user)
} yield address
          

As long as map and flatMap are defined on the class.

Different monads, different behaviour:

  • Option: The ability to fail fast
  • \/: The ability to fail fast, telling us about the failure
  • Future: Perform computations concurrently
  • Reader: Provide a read-only environment
  • Id: Do nothing special (???)

Abstraction over monads

Ficticious scenario:


def getUser(id: Int): Future[User]
def getAddress(user: User): Future[Address]
          

def addressFromUserId(userId: Int): Future[Address] = {
  for {
    user    <- getUser(userId)
    address <- getAddress(user)
  } yield address
}
          

Abstraction over monads

Refactoring:


def addressFromUserId(getUserFunc:    Int => Future[User], 
                      getAddressFunc: User => Future[Address])
                     (userId: Int): Future[Address] = {
  for {
    user    <- getUserFunc(userId)
    address <- getAddressFunc(user)
  } yield address
}
          

val userTestF: Int => Future[User] = 
                           i => Future.successful(User(i, "Bob", "Smith"))

val addressTestF: User => Future[Address] = 
                           _ => Future.successful(Address("Paris"))

val wiringTest = addressFromUserId(userTestF, addressTestF)(1234)

          

assert(Await.result(wiringTest...
          

Abstraction over monads

More Refactoring:


def addressFromUserId[M[_]: Monad](getUserFunc:    Int => M[User], 
                                   getAddressFunc: User => M[Address])
                                  (userId: Int): M[Address] = {
  for {
    user    <- getUserFunc(userId)
    address <- getAddressFunc(user)
  } yield address
}
          

val userTestF: Int => Id[User] = i => User(i, "Bob", "Smith")
val addressTestF: User => Id[Address] = _ => Address("Paris")
          

val wiringTest = addressFromUserId[Id](userTestF, addressTestF)(1234)
          

assert(wiringTest...
          

scala> :type wiringTest
scalaz.Scalaz.Id[Address]
          

scala> val address: Address = wiringTest
address: Address = Address(Paris)
          

Abstraction over monads


def runLongCalc(a: Int, b: Int): Future[Int] = {
  Future {
    // ... expensive calculating here ...
  }
}
          

def runLongCalc[M[_]: Monad](a: Int,b: Int)(implicit m: Monad[M]): M[Int] = {
  m.point {
    // ... expensive calculating here ...
  }
}
          

scala> runLongCalc[Future](10, 5)
res35: scala.concurrent.Future[Int] = ...

scala> runLongCalc[Id](10, 5)
res34: scalaz.Scalaz.Id[Int] = ...
          

Thank you

Useful links



Noel Markham

Slides: http://noelmarkham.github.io/scalaz-scala.io