Akka。如何用Source.actorRef完成一個流？

我想完成與預定義的消息的流數：Akka。如何用Source.actorRef完成一個流？

Source.actorRef(Integer.MAX_VALUE, OverflowStrategy.fail()) 
    .limit(1) 
    .to(Sink.onComplete(System.out::println)) 
    .run(materializer); 
    .tell("Do Complete!", ActorRef.noSender());

從限制方法文檔：

完成時所定義的元素的數目已經採取或上游完成

爲什麼流不完整？

來源

2017-05-25 Andrew Inzer

這是take的文檔，而不是limit。

事實上，你應該使用take來解決你的問題。

來源

2017-05-25 12:41:55

謝謝，它的工作原理！ –

PS：在javadoc中，限制方法具有相同的描述（http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Source.html#limit-int-） –

複製粘貼錯誤，我猜.. 這個文檔頁面通常更可靠http://doc.akka.io/docs/akka/2.5/java/stream/stages-overview.html –

Akka。如何用Source.actorRef完成一個流？

回答

相關問題