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
Version | Downloads | Last updated | |
---|---|---|---|
2.2.5 | 31 | 1/31/2019 | |
2.2.4 | 30 | 1/31/2019 | |
2.2.3 | 30 | 1/31/2019 | |
2.2.2 | 30 | 1/31/2019 | |
2.1.1 | 29 | 1/31/2019 | |
2.1.0 | 33 | 1/30/2019 | |
2.1.0-beta | 28 | 1/30/2019 | |
2.0.0 | 82 | 12/18/2018 | |
2.0.0-beta2 | 68 | 12/13/2018 | |
2.0.0-beta1 | 74 | 12/13/2018 | |
1.0.1 | 254 | 8/6/2016 | |
1.0.0 | 180 | 8/6/2016 |