No description
Flow(x).map(x => Flow(...)) type of setups would previously use the generator incorrectly if the streams were created within an actor. This is fixed now by making all stream-support actors set a ThreadLocal which tells ActorBasedProcessorGenerator to override its contained ActorRefFactory with the locally provided one. |
||
|---|---|---|
| akka-stream/src | ||