Advertisement
Guest User

Untitled

a guest
Aug 28th, 2016
53
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.35 KB | None | 0 0
  1. trait Sink[-To] {
  2. def apply(t: To): Unit
  3. def stage[E]: StagedSink[E, To]
  4. }
  5.  
  6. trait StagedSink[Current, Final] {
  7. def map[B](f: Current => B)(implicit isDone: CanSink[B, Final, To]): To
  8. def flatMap[B](f: Current => TraversableOnce[B])(implicit isDone: CanSink[B, Final, To]): To
  9. def withFilter(f: Current => Boolean): StagedSink[Current,Final]
  10. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement