Как получить доступ к методу OfferAsync Source.Queue при использовании графиков Akka.Net? ⇐ C#

[Гость]

Я работаю над приложением Akka.net Streams, которое использует Graph API. Я хотел бы предоставить исходные данные с помощью метода OfferAsync Source.Queue.

Как получить доступ к методу ISourceQueueWithComplete.OfferAsync после создания графа для добавления данных в поток?

Вот код, который я использую для создания графика:
// Создаем график var runnableGraph = RunnableGraph.FromGraph(GraphDsl.Create( строитель => { // создаем источник var sourceQueue = Source.Queue(100, OverflowStrategy.Fail) // используем конструктор для настройки графика ... } // запускаем график runnableGraph.Run(материализатор);
Вот код, который я хочу использовать для получения данных для потока:
while (true) { вар события = GetEventsFromExternalSource(); foreach (var singleEvent в событиях) { sourceQueueWithComplete.OfferAsync(singleEvent); } }