Akka. Wie beende ich einen Stream mit Source.actorRef?

Ich mag würde einen Stream mit vordefinierten Nachrichten vervollständigen zählen:Akka. Wie beende ich einen Stream mit Source.actorRef?

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

Von der Grenze Methode Dokumentation:

schließt, wenn die definierte Anzahl von Elementen hat oder stromaufwärts abgeschlossen ist genommen worden,

Warum ist der Stream nicht vollständig?

Quelle

2017-05-25 Andrew Inzer

Das ist die Dokumentation für take, nicht limit.

Und in der Tat sollten Sie take verwenden, um Ihr Problem zu lösen.

Quelle

2017-05-25 12:41:55

Danke, es funktioniert! –

PS: im Javadoc hat die Limit-Methode die gleiche Beschreibung (http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Source.html#limit-int-) –

Copy-Paste-Fehler , Ich denke .. diese doc-Seite ist in der Regel zuverlässiger http://doc.akka.io/docs/akka/2.5/java/stream/stages-overview.html –

Akka. Wie beende ich einen Stream mit Source.actorRef?

Antwort

Verwandte Themen