1 - triagedhelp wantedt:stream
Repository metrics
- Stars
- (13,277 個のスター)
- PR merge metrics
- (平均マージ 8d 19h) (30d で 10 merged PRs)
説明
When working on https://github.com/akka/akka-persistence-cassandra/pull/888 I realized that it wasn't obvious how to set a dispatcher all the way to the Sink (and not introduce async boundary).
My first thought, when I didn't realize that the Sink is also involved, was:
.map(stuff)
.withAttributes(ActorAttributes.dispatcher(theDispatcher))
.runWith(Sink.ignore)
but it should be:
.map(stuff)
.toMat(Sink.ignore)(Keep.right)
.withAttributes(ActorAttributes.dispatcher(theDispatcher))
.run()