Create Flow[ByteString, ByteString, NotUsed] by piping through InputStream
I need decompress data using compression not supported by akka, but supported by other library which provided InputStream interface.
To make it work with akka stream, I need to implement function:
How to create akka source that is materialized to ActorRef in which the incoming messages know the sender
val ref = Source.actorRef[String]( completionMatcher = PartialFunction.empty, failureMatcher = PartialFunction.empty, 100000, OverflowStrategy.dropNew ).to(Sink.foreachAsync(1){ elem => // how to reply to sender Future.successful() }) Above is example that does nearly what I need, with the exception that the underlying message does not know the sender. So it’s impossible to reply. Is there a way or pattern […]