trait Sink[A] {
def apply(a: A): Async[Unit]
final def contraMap[B](f: B => A): Sink[B] =
b => apply(f(b))
}
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
trait Sink[A] {
def apply(a: A): Async[Unit]
final def contraMap[B](f: B => A): Sink[B] =
b => apply(f(b))
}