Observable
Namespace: Gjallarhorn
Additional functions related to Observable for use with Gjallarhorn
Nested types and modules
| Module | Description |
| Subscription |
Functions and values
| Function or value | Description |
filterBy condition input
Signature: condition:ISignal<bool> -> input:IObservable<'?7676> -> IObservable<'?7676>
Type parameters: '?7676 |
Filters the input observable by using a separate bool signal. The value of the signal is used as the filtering predicate |
filterSome provider
Signature: provider:IObservable<'a option> -> IObservable<'a>
Type parameters: 'a |
Filters out observables of options to only pass through "Some" values |
mapAsync mapping provider
Signature: mapping:('a -> Async<'b>) -> provider:IObservable<'a> -> IObservable<'b>
Type parameters: 'a, 'b |
Maps the input observable through an async workflow. |
mapAsyncTracked mapping tracker provider
Signature: mapping:('a -> Async<'b>) -> tracker:IdleTracker -> provider:IObservable<'a> -> IObservable<'b>
Type parameters: 'a, 'b |
Maps the input observable through an async workflow. Execution status is reported through the specified IdleTracker. |
toMessage mapping provider
Signature: mapping:('a -> 'b) -> provider:IObservable<'a option> -> IObservable<'b>
Type parameters: 'a, 'b |
Converts an observable stream of options into a message type when valid |
