Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var props = new RoundRobinPool(5).Props(Props.Create<MyActor>());
- var actor = Context.ActorOf(props);
- flow = Source.Queue<Element>(2000,OverflowStrategy.Backpressure)
- .Select(x => {
- return new Wrapper() { Element = x, Request = ++cnt };
- })
- .To(Sink.ForEachParallel<Wrapper>(5, (s) => { actor.Tell(s); }))
- .Run(materializer);
Add Comment
Please, Sign In to add comment