Posting my owner discovery for future readers/searchers, especially since
it's so simple :)
The short answer: splitWhen(ign => true)
The code is probably not idiomatic, being my second short foray into scala.
It does compile and run on my setup. Any general thoughts/improvements are
Thanks for the follow up -- the idea you posted is related, but not quite
it.
I wrote a self-contained working example below. What I do in this example
is manually materialize a graph, and wrap it as a future, making it usable
by mapAsync.
*Ideal: to define an entire graph such that the
Hi,
I am new to akka streams, and working on a project having both real-time
and batch needs. In the batch cases, I need to take context (e.g.,
requestID), from the initial request, and apply it at the end of batch-item
processing. The batch-item subflow is by itself rather simple: (parse,
