1 - triagedhelp wantednice-to-have (low-prio)
倉庫指標
- 星標
- (1,311 顆星)
- PR 合併指標
- (平均合併 1天 10小時) (30 天內合併 2 個 PR)
描述
Issue by drewhk Thursday Dec 17, 2015 at 12:08 GMT Originally opened as https://github.com/akka/akka/issues/19218
What is needed is roughly:
val uploadSink = Flow[ByteString].lift.map(<put Source in HttpRequest>).via(http).to(Sink.ignore)
Where lift is the magic that makes Source[T] to Source[Source[T]].