- Source:
Members
(static, constant) exports.average
- Source:
Takes an average of everything coming into the event stream until it completes
(static, constant) exports.combine
- Source:
combines multiple observables at the same time.
it will only call the observer's next function when all observables have emitted at least one value
(static, constant) exports.concat
- Source:
Concatenate any number of observables together
(static, constant) exports.count
- Source:
Counts the number of values coming into the stream on complete
(static, constant) exports.debounceTime
- Source:
Debounces values that will be sent down the stream.
Will only output values if there has not been any new values in the past time interval passed
(static, constant) exports.delay
- Source:
Will delay output from the observable until a specific time interval has passed
(static, constant) exports.doStuff
- Source:
Will run some callback before passing the current value to the subscription
Example
doStuff(obs$, (value) => console.log(value))
.subscribe((sameValue) => console.log('Will log the same value: ', sameValue))l(static, constant) exports.filter
- Source:
Will filter out values that you do not want to subscribe to
(static, constant) exports.first
- Source:
Will take the first value from the observable and then complete
This is an alias for take(obs$, 1, callback)
(static, constant) exports.flatMap
- Source:
Same as map(obs$, mapCallback) but will take the value of the callback and turn it from an observable to a value
(static, constant) exports.map
- Source:
Will map each value to a new value using the callback
(static, constant) exports.max
- Source:
Will result in the maximum value passed to the observer then will complete
(static, constant) exports.merge
- Source:
Will merge any number of observables into one observable stream
(static, constant) exports.min
- Source:
Will result in the minimum value passed to the observer then will complete
(static, constant) exports.reduce
- Source:
Sort of the same way that Array.reduce works, it will concatenate all of the values
passing through an Observable event stream with a given scanCallback
(static, constant) exports.scan
- Source:
(static, constant) exports.sum
- Source:
Sums all the values of an observable upon completion
(static, constant) exports.switchMap
- Source:
The value from the mapCallback is an observable and if another value comes through the previous observable is cancelled
This is useful for things like typeaheads where you dont want a request for every keypress
(static, constant) exports.take
- Source:
Takes a number of values that satisfy the filterCallback then completes
(static, constant) exports.takeUntil
- Source:
Takes values from the source$ until the takeSource$ emits one value
(static, constant) exports.toPromise
- Source:
Reverse of fromPromise
Converts an Observable to a promise, takes the first value and then completes
(static, constant) exports.zip
- Source: