Akka.net создает собственный поток для mqtt

Question

Мне нужно создать поток akka с помощью mqtt.

случай использования: сообщения публикуются в канале mqtt, мне нужно получить эти сообщения в виде потока akka.

пример использования будет выглядеть ниже.

          mqttstream.
            .Buffer(50, OverflowStrategy.DropHead)
            .Throttle(1, TimeSpan.FromSeconds(1), 1, ThrottleMode.Shaping)
            .RunForeach((gpsPoint) => {
                Console.WriteLine("actor got gps cordinates");{gpsPoint.Lattitude}, longitude: {gpsPoint.Longitude}");

            }, materializer);

Итак, чтобы закончить, поток akka должен выложить любое сообщение, опубликованное на канал mqtt.