java - Akka 。如何使用 Source.actorRef 完成流？

Question

我想用预定义的消息数来完成一个流:

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

来自限制方法文档:

Completes when the defined number of elements has been taken or upstream completes

为什么流没有完成？

Answer 1

那是take的文档，不是limit。

确实，您应该使用take 来解决您的问题。