Hi Johannes, thanks for your answer and especially for the sample code (it helped me quite a lot to understand the approach) !
If I understand it correct this *Source.subscriber[T].toMat(Sink.publisher[T])(Keep.both).run() * essentially exposes a* reactive stream* Publisher and Subscriber interface, which can in turn be wrapped as a *akka streams *Source and Sink. (related https://github.com/akka/akka/issues/16923) Following some assumptions / questions 1. the Source and Sink from the activePipe can *not *be "reused" in a different materialization (however thats not a problem, the WebSocket can anyway not be materialized again) 2. backpressure works on both streams (left and right of the pipe) normally 3. the pipe itself does not have an akka backpressure strategy, it is just a "body-less" connector of the two streams i.e. once the right stream starts demanding the left stream starts sending (I tried this out and interestingly the first stream although complete and materialized does not consume items until the 2nd stream gets materialized as well. After that "max in flight" many traverse the first stream) 4. Error handling should work as well (probably, I should test that) 5. if streams are used in a dynamic way the "rematerializable / blueprint" akka streams DSL does not work out, instead we have to use the reactive streams API which allows dynamic binding (e.g. as soon as the 2nd WebSocket is available) 6. buy using your approach we avoid a more complicated actor implementation + can profit from upcoming Non-Actor-Materializers If you have any knowledge / further insights regarding these points I would appreciate that in any case thanks again! best Michael -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
