Advertisement
Guest User

Untitled

a guest
Apr 19th, 2019
106
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.33 KB | None | 0 0
  1. from reactive programms edx course
  2.  
  3. // Utilities to temporarily have unimplemented parts of the program
  4.  
  5. private def unimplementedFlow[A, B, C]: Flow[A, B, C] =
  6. Flow.fromFunction[A, B](_ => ???).mapMaterializedValue(_ => ??? : C)
  7.  
  8. private def unimplementedSink[A, B]: Sink[A, B] = Sink.ignore.mapMaterializedValue(_ => ??? : B)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement