akka.net-streams - 如何将项目排入 akka.net 队列源

Question

在 akka.net 流中创建队列源后，如何将项目添加到队列中？创建的对象中没有 Enqueue、Add 或 Offer 方法。

Source<int, ISourceQueueWithComplete<int>> source = 
   Source.Queue<int>(100, OverflowStrategy.Backpressure);

Answer 1

它是 OfferAsync，您可以在单元测试中举个例子，例如https://github.com/akkadotnet/akka.net/blob/master/src/core/Akka.Streams.Tests/Dsl/QueueSourceSpec.cs