Any chance that this is related
to
https://groups.google.com/forum/#!searchin/akka-user/disapear/akka-user/QZhDFmrXZaY/_NgOM9O0wmkJ
?
Am Donnerstag, 16. April 2015 20:31:56 UTC+2 schrieb rkuhn:
Great detective work, Rick, thanks a lot!
16 apr 2015 kl. 15:37 skrev Rick Latrine
I don't have the time to actually try this now, but one way to achieve this
comes to mind:
The ActorCell underneath should have access to the message currently in
work.
AFAIK, you can cast the context to ActorCell and just read the current
message out of it.
For good reason, however, the
Hi everyone,
we are currently integrating Akka-Streams in an application.
Looking at the current Flow DSL/API, I can see that Transformers
(Flow#transform) allow to *synchronously* produce a number of
output-messages from 1 message.
abstract class Transformer[-T, +U] {
* /***
* * Invoked
Awesome - thanks for the quick reply!
You're right - the Transformer-Pull is probably not exactly what I need.
But I can make due with your other proposals for now.
Thx,
-Thomas
Am Mittwoch, 16. Juli 2014 11:11:36 UTC+2 schrieb drewhk:
Hi!
On Wed, Jul 16, 2014 at 10:49 AM, schoefts