MQTTnet.Rx.Client
1.2.2
See the version list below for details.
dotnet add package MQTTnet.Rx.Client --version 1.2.2
NuGet\Install-Package MQTTnet.Rx.Client -Version 1.2.2
<PackageReference Include="MQTTnet.Rx.Client" Version="1.2.2" />
paket add MQTTnet.Rx.Client --version 1.2.2
#r "nuget: MQTTnet.Rx.Client, 1.2.2"
// Install MQTTnet.Rx.Client as a Cake Addin #addin nuget:?package=MQTTnet.Rx.Client&version=1.2.2 // Install MQTTnet.Rx.Client as a Cake Tool #tool nuget:?package=MQTTnet.Rx.Client&version=1.2.2
MQTTnet.Rx.ManagedClient
MQTTnet.Rx.ABPlc
MQTTnet.Rx.Modbus
MQTTnet.Rx.S7Plc
MQTTnet.Rx.SerialPort
MQTTnet.Rx.TwinCAT
<p align="left"> <a href="https://github.com/ChrisPulman/MQTTnet.Rx"> <img alt="MQTTnet.Rx" src="https://github.com/ChrisPulman/MQTTnet.Rx/blob/main/Images/logo.png" width="200"/> </a> </p>
MQTTnet.Rx.ManagedClient
A Reactive Managed Client for MQTTnet Broker
Create a Mqtt Client to Publish an Observable stream
Create.MqttClient()
.WithClientOptions(a => a.WithTcpServer("localhost", 9000))
.PublishMessage(_message)
.Subscribe(r => Console.WriteLine($"{r.ReasonCode} [{r.PacketIdentifier}]"));
Create a Managed Mqtt Client to Publish an Observable stream
Create.ManagedMqttClient()
.WithManagedClientOptions(a =>
a.WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
.WithClientOptions(c =>
c.WithTcpServer("localhost", 9000)))
.SubscribeToTopic("FromMilliseconds")
.Subscribe(r => Console.WriteLine($"{r.ReasonCode} [{r.ApplicationMessage.Topic}] value : {r.ApplicationMessage.ConvertPayloadToString()}"));
Create a Mqtt Client to Subscribe to a Topic
Create.MqttClient()
.WithClientOptions(a => a.WithTcpServer("localhost", 9000))
.SubscribeToTopic("FromMilliseconds")
.Subscribe(r => Console.WriteLine($"{r.ReasonCode} [{r.ApplicationMessage.Topic}] value : {r.ApplicationMessage.ConvertPayloadToString()}"));
Create a Managed Mqtt Client to Subscribe to a Topic
Create.ManagedMqttClient()
.WithManagedClientOptions(a =>
a.WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
.WithClientOptions(c =>
c.WithTcpServer("localhost", 9000)))
.SubscribeToTopic("FromMilliseconds")
.Subscribe(r => Console.WriteLine($"{r.ReasonCode} [{r.ApplicationMessage.Topic}] value : {r.ApplicationMessage.ConvertPayloadToString()}"));
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
.NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen40 was computed. tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- MQTTnet.Extensions.ManagedClient (>= 4.3.1.873)
- Newtonsoft.Json (>= 13.0.3)
- System.Reactive (>= 6.0.0)
-
net6.0
- MQTTnet.Extensions.ManagedClient (>= 4.3.1.873)
- Newtonsoft.Json (>= 13.0.3)
- System.Reactive (>= 6.0.0)
-
net7.0
- MQTTnet.Extensions.ManagedClient (>= 4.3.1.873)
- Newtonsoft.Json (>= 13.0.3)
- System.Reactive (>= 6.0.0)
NuGet packages (5)
Showing the top 5 NuGet packages that depend on MQTTnet.Rx.Client:
Package | Downloads |
---|---|
MQTTnet.Rx.Modbus
Reactive extensions for MQTTnet Broker |
|
MQTTnet.Rx.TwinCAT
Reactive extensions for MQTTnet Broker |
|
MQTTnet.Rx.S7Plc
Reactive extensions for MQTTnet Broker |
|
MQTTnet.Rx.ABPlc
Reactive extensions for MQTTnet Broker |
|
MQTTnet.Rx.SerialPort
Reactive extensions for MQTTnet Broker |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
2.1.1 | 184 | 8/16/2024 |
2.0.1 | 299 | 3/19/2024 |
1.3.1 | 322 | 12/26/2023 |
1.2.2 | 360 | 10/16/2023 |
1.2.1 | 230 | 10/15/2023 |
1.1.1 | 274 | 9/7/2023 |
1.1.0 | 389 | 8/19/2023 |
1.0.0 | 207 | 7/5/2023 |
0.9.1 | 166 | 6/11/2023 |
0.9.0 | 347 | 4/25/2023 |
0.9.0-g916413e22f | 90 | 6/24/2023 |
0.8.0 | 660 | 3/18/2023 |
0.7.0 | 1,388 | 1/1/2023 |
0.6.0 | 444 | 12/6/2022 |
0.5.0 | 1,094 | 10/29/2022 |
0.4.0 | 869 | 8/8/2022 |
0.3.0 | 912 | 8/2/2022 |
0.2.0 | 382 | 7/31/2022 |
0.1.2 | 367 | 7/28/2022 |
0.1.1 | 373 | 7/28/2022 |
Compatability with Net 6 / 7 and netstandard2.0