Factory helpers for creating common ISub values. More...
Static Public Member Functions | |
| static ISub | FromAsyncEnumerable (Func< CancellationToken, IAsyncEnumerable< IMsg > > factory) |
| Wrap an arbitrary IAsyncEnumerable<IMsg> factory as a subscription. | |
| static ISub | FromObservable (IObservable< IMsg > observable) |
| Wrap an IObservable<IMsg> as a subscription. | |
| static ISub | Interval (TimeSpan interval, Func< DateTimeOffset, IMsg > fn) |
| A subscription that fires fn every interval . | |
Factory helpers for creating common ISub values.
Wrap an IObservable<IMsg> as a subscription.
Messages are forwarded until the token is cancelled or the observable completes.
A subscription that fires fn every interval .
Messages are produced indefinitely until the token is cancelled.