A extension to the MQTTnet project, to transform the subscriptions into observables and to publish form a observalbe stream.
Use the MQTTnet.MqttFactory wiht the MQTTnet.Extensions.External.RxMQTT.Client.MqttFactoryExtensions
var client = new MqttFactory().CreateRxMqttClient();Use the managed clinent options
awiat client.StartAsync(options).ConfigureAwait(false);Get a IObservable<MqttApplicationMessageReceivedEventArgs> by connecting to the rx client and use extensions to process the message:
var subscription = rxMqttClinet
.Connect("RxClientTest/#")
.GetPayload()
.Subscribe(Console.WriteLine);To end the subscribtion dispose the subscribtion.
subscription.Dispose();Create a observalbe sequenc of MqttApplicationMessages and publish them via the rx client.
Observable.Interval(TimeSpan.FromMilliseconds(1000))
.Select(i => new MqttApplicationMessageBuilder()
.WithTopic("RxClientTest")
.WithPayload("Time: " + DateTime.Now.ToLongTimeString())
.WithExactlyOnceQoS()
.WithRetainFlag()
.Build())
.PublishOn(mqttClient)
.Subscribe();Use the mqtt client publish method.