1

在 Akka Streams (java api) 中,当 ActorSubscriber 死亡时上游会发生什么?直播会被取消吗?我使用 akka 2.4 和 akka 流实验 1.0 和 jdk 8

代码如下所示:

Materializer chunkerMat = ...

    Source<Buffer, BoxedUnit> bufferSource = ...

    Sink<Buffer, ActorRef> sink = Sink.<Buffer>actorSubscriber(Props.create(new AkkaVertxSubscriber.Creator(response)));

    bufferSource.runWith(sink, chunkerMat);
4

0 回答 0