TNX.Reactive 2.2.5

[.NET 4.6.1+]

- DisposableObservable: a class for creating Observable sequences with TPL easily as Observable.Create
- [IObservable].Serialize: wrap all subscriptions into a single ISubject against the sourcing observable
- [IObservable].AsAsync: execute all functions on TPL
- [IObservable].Fork: add another subscription to the observable creating a new child observable stream
- [IObservable].Where(filter, elseObservable): apply the where in the usual way, and generate an Else observable to continue work in the other case
- [IObservable].ToJson: serialize in Json all values
- [IObservable].ToCSV: serialize in CSV columns all values (configurable delimiter)
- [IObservable].OnLastOrDefault: do something when observable completes

- ObservableStreamReader: route binary data from a Stream to subscribers

Release Notes

- FIX and refactory

Dependencies

• • Newtonsoft.Json (>= 10.0.3)
  • System.Reactive (>= 4.1.2)

Version History