Info
| Version: | 2.2.5 |
| Author(s): | Antonio Esposito |
| Last Update: | Thursday, January 31, 2019 |
| .NET Fiddle: | Create the first Fiddle |
| Project Url: | http://www.tnxconsulting.com/ |
| NuGet Url: | https://www.nuget.org/packages/TNX.Reactive |
Install
Install-Package TNX.Reactive
dotnet add package TNX.Reactive
paket add TNX.Reactive
TNX.Reactive Download (Unzip the "nupkg" after downloading)
Dependencies
- System.Reactive(>= 4.1.2)
- Newtonsoft.Json(>= 10.0.3)
Tags
- 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.