Как поставить элементы в очередь в akka.net

Как я могу добавить элементы в очередь после создания источника очереди в потоках akka.net? В созданном объекте нет метода Enqueue, Add или Offer.

Source<int, ISourceQueueWithComplete<int>> source = 
   Source.Queue<int>(100, OverflowStrategy.Backpressure);
Источник

1 ответ

Это OfferAsync, вы можете иметь пример на модульных тестах, например, https://github.com/akkadotnet/akka.net/blob/master/src/core/Akka.Streams.Tests/Dsl/QueueSourceSpec.cs

Источник
Другие вопросы по тегам