Scalaz

Or: How I learned to stop worrying and love monads

London Scala Meetup - 11 February 2015

Noel Markham - @noelmarkham

Hello :-)


Schedule

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

"org.scalaz" %% "scalaz-core" % "7.1.1"
          

import scalaz._
import Scalaz._
          

Enhancements out of the box

Booleans

.option


scala> (6 < 10).option("corrie")
res0: Option[String] = Some(corrie)

scala> (6 > 10).option("emmerdale")
res1: Option[String] = None
	  

Neater than:


scala> if(6 < 10) Some("corrie") else None
res2: Option[String] = Some(corrie)
	  

Enhancements out of the box

Strings

.parseXXX


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

scala> val b = "corrie".parseBoolean
b: Validation[
     IllegalArgumentException,
     Boolean] =
 Failure(IllegalArgumentException:
                 For input string: "corrie")
          

Enhancements out of the box

Lists

.allPairs


> List(1, 2, 3).allPairs.foreach(println)
(1,2)
(2,3)
(3,4)
(1,3)
(2,4)
(1,4)
          

Enhancements out of the box

Lists

.powerset


> 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> "corrie".some
res6: Option[String] = Some(corrie)
          

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

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

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

Enhancements out of the box

All types

.some


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

> 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

“Biased” to the right


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

scala> res.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

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
}
          

Typeclasses

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

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

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

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

Typeclasses

A simple example

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] {
  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

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("A", "BB").foldMap(_.length)
res22: Int = 3
          

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 numbers from a map and divide one by the other

Retrieve a number 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(num: Int, denom: 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(num: Int, denom: Int): Option[Int]
          

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

All return some type with some auxiliary 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[A,B](f:A => M[B]) = bind(self)(f)
 def >>=[A,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) =
      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
}
          

Abstraction over monads

Refactoring:


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

val addrTestF: User => Future[Address] = 
      _ => Future(Address("London"))

val wiringTest =
    addressFromUserId(userTestF, addrTestF)(1)

          

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
}
          

Abstraction over monads

More Refactoring:


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

val wiringTest = addressFromUserId[Id]
                    (userTestF, addrTestF)(1)
          

assert(wiringTest, ...
          

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

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

Abstraction over monads


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

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

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

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

Thank you

Useful links



Noel Markham

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