1 - triagedhelp wantedt:stream
仓库指标
- 星标
- (13,277 个星标)
- PR 合并指标
- (PR 指标待抓取)
描述
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()