Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- trait Sink[-To] {
- def apply(t: To): Unit
- def stage[E]: StagedSink[E, To]
- }
- trait StagedSink[Current, Final] {
- def map[B](f: Current => B)(implicit isDone: CanSink[B, Final, To]): To
- def flatMap[B](f: Current => TraversableOnce[B])(implicit isDone: CanSink[B, Final, To]): To
- def withFilter(f: Current => Boolean): StagedSink[Current,Final]
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement