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