Finally ended with
```scala
val managedMySource = FlowGraph.partial(MySource()) {
implicit b => source =>
val control = b.add(Flow[Command]])
val zip = b.add(Zip[ActorRef, Command])
b.materializedValue.map(Source.repeat).flatten(FlattenStrategy.concat) ~>
zip.in0
The problem with this solution is absence of actorRef during upstream
complete. Any ideas how to get it?
пятница, 16 октября 2015 г., 15:18:51 UTC+6 пользователь Alexey Romanchuk
написал:
>
> Finally ended with
>
> ```scala
> val managedMySource = FlowGraph.partial(MySource()) {
> implicit
Hi Alexey,
I don't have any suggestion for a fix, but it does seem like your setup is
a bit too entangled.
If you take a step back and look at the lifecycle and propagation pattern
needed by your solution, is it workable or does it make sense to consider
other solutions?
On Mon, Oct 19, 2015 at 7
