MyNatsClient.Rx 0.13.0

Install-Package MyNatsClient.Rx -Version 0.13.0
dotnet add package MyNatsClient.Rx --version 0.13.0
<PackageReference Include="MyNatsClient.Rx" Version="0.13.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add MyNatsClient.Rx --version 0.13.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: MyNatsClient.Rx, 0.13.0"
#r directive can be used in F# Interactive, C# scripting and .NET Interactive. Copy this into the interactive tool or source code of the script to reference the package.
// Install MyNatsClient.Rx as a Cake Addin
#addin nuget:?package=MyNatsClient.Rx&version=0.13.0

// Install MyNatsClient.Rx as a Cake Tool
#tool nuget:?package=MyNatsClient.Rx&version=0.13.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Pub-Sub sample

Simple pub-sub sample showing one client that publishes and one that subscribes. This can of course be the same client and you can also have more clients subscribing etc.

Publisher

var cnInfo = new ConnectionInfo("192.168.1.10");
var client = new NatsClient(cnInfo);

await client.PubAsync("tick", GetNextTick());

//or using an encoding package e.g. Json
await client.PubAsJsonAsync("tickItem", new Tick { Value = GetNextTick() });

Subscriber

var cnInfo = new ConnectionInfo("192.168.1.10");
var client = new NatsClient(cnInfo);

await client.SubAsync("tick", stream => stream.Subscribe(msg => {
    Console.WriteLine($"Clock ticked. Tick is {msg.GetPayloadAsString()}");
}));

//or using an encoding package e.g Json
await client.SubAsync("tickItem", stream => stream.Subscribe(msg => {
    Console.WriteLine($"Clock ticked. Tick is {msg.FromJson<TestItem>().Value}");
}))

Stream.Subscribe vs Stream.SubscribeSafe

If you subscribe to e.g. the MessageOpStream using Stream.Subscribe and your handler is throwing an exception. That handler will get OnError invoked and then removed.

await client.SubAsync("mySubject", stream => stream.Subscribe(msg => DoSomething(msg)));

If you instead subscribe using Stream.SubscribeSafe any unhandled exception will get swallowed.

await client.SubAsync("mySubject", stream => stream.SubscribeSafe(msg => DoSomething(msg)));

Request-Response sample

Simple request-response sample. This sample also makes use of two clients. It can of course be the same client requesting and responding, you can also have more responders forming a queue group. Where one will be giving the answer.

Requester

var cnInfo = new ConnectionInfo("192.168.1.10");
var client = new NatsClient(cnInfo);

var response = await client.RequestAsync("getTemp", "stockholm@sweden");
Console.WriteLine($"Temp in Stockholm is {response.GetPayloadAsString()}");

Responder

var cnInfo = new ConnectionInfo("192.168.1.10");
var client = new NatsClient(cnInfo);

await client.SubAsync("getTemp", stream.Subscribe(msg => {
    client.Pub(msg.ReplyTo, getTemp(msg.GetPayloadAsString()));
}));
There are no supported framework assets in this package.

Learn more about Target Frameworks and .NET Standard.

NuGet packages (3)

Showing the top 3 NuGet packages that depend on MyNatsClient.Rx:

Package Downloads
M5x.Nats

Package Description

Mi.Fx.Nats

macula.io Nats abstraction

Mi.Fx.Contract

Package Description

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
0.13.0 47,664 6/29/2018
0.12.0 713 6/29/2018
0.12.0-pre1 777 5/4/2018
0.11.0 31,071 1/26/2017
0.10.0 21,969 1/10/2017
0.8.0 836 1/4/2017
0.7.0 1,067 12/23/2016
0.6.0 914 12/4/2016
0.5.1 958 10/18/2016
0.5.0 835 10/17/2016
0.4.0 845 10/16/2016
0.3.0 814 10/8/2016
0.3.0-b1 800 10/6/2016
0.2.1 1,572 6/14/2016