I may have misunderstood what you're trying to do but I think you can
probably use expand for this. In builder pseudocode, something like:
Flow ~> Unzip ~> ~> Zip
~> Flow.expand(Iterator.continually(_))~>
The expand step will duplicate the last element it received which m
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 materi
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
appreciate
