<commit_before># NetMQ.ReactiveExtensions

*Note: This project is sample code only at the moment, the NuGet package is in progress.*

Effortlessly send messages anywhere using Reactive Extensions (RX). Uses NetMQ as the transport layer.

The libary is very simple to use. With a couple of lines of code, we can send any RX stream anywhere on the network.

The API is a drop-in replacement for `Subject<T>` from Reactive Extensions (RX).

As a refresher, to use `Subject<T>` in Reactive Extensions (RX):

```csharp
Subject<int> subject = new Subject<int>();
subject.Subscribe(message =>
{
	// Receives 42.
});
subject.OnNext(42);
```

The new API is virtually identical:<commit_msg>Updated Readme.md.<commit_after># NetMQ.ReactiveExtensions

*Note: This project is sample code only at the moment, the NuGet package is in progress.*

Effortlessly send messages anywhere on the network using Reactive Extensions (RX).

Uses NetMQ as the transport layer.

The API is a drop-in replacement for `Subject<T>` from Reactive Extensions (RX).

As a refresher, to use `Subject<T>` in Reactive Extensions (RX):

```csharp
Subject<int> subject = new Subject<int>();
subject.Subscribe(message =>
{
	// Receives 42.
});
subject.OnNext(42);
```

The new API is virtually identical:
{'fraction_non_alphanumeric': 0.09881422924901186, 'fraction_numerical': 0.006324110671936759, 'mean_word_length': 4.780821917808219, 'pattern_counts': {'":': 0, '<': 11, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1129677', 'n_tokens_mistral': 393, 'n_tokens_neox': 369, 'n_words': 165}