RxJS Complete Module
The Reactive Extensions for JavaScript's complete functionality is in the complete RxJS file which has many core components including the Schedulers, Disposables, Observable and Observer, but omits any testing capabilities.
This comes with both rx.all.js
which is for use in modern development environments such as > IE9 and server-side environments such as Node.js. We also have rx.all.compat.js
which has backwards compatibility to browsers which do not support all required ES5 features.
Details
Files:
NPM Packages:
NuGet Packages:
Included Observable Operators
Observable Methods
amb
case | switchCase
catch | catchError
concat
create
defer
empty
for | forIn
forkJoin
from
fromArray
fromCallback
fromEvent
fromEventPattern
fromNodeCallback
fromPromise
generate
generateWithAbsoluteTime
generateWithRelativeTime
if | ifThen
interval
just
merge
mergeDelayError
never
of
ofArrayChanges
ofObjectChanges
ofWithScheduler
onErrorResumeNext
range
repeat
return
start
startAsync
throw | throwError
timer
toAsync
using
when
while | whileDo
zip
zipArray
Observable Instance Methods
aggregate
all
amb
and
any
asObservable
average
buffer
bufferWithCount
bufferWithTime
bufferWithTimeOrCount
catch | catchException
combineLatest
concat
concatAll
concatMap
connect
includes
controlled
count
debounce
debounceWithSelector
defaultIfEmpty
delay
delaySubscription
delayWithSelector
dematerialize
distinct
distinctUntilChanged
do
doOnNext
doOnError
doOnCompleted
doWhile
elementAt
elementAtOrDefault
every
expand
extend
filter
finally | finallyAction
find
findIndex
first
firstOrDefault
flatMap
flatMapLatest
flatMapObserver
forkJoin
groupBy
groupByUntil
groupJoin
ignoreElements
isEmpty
join
last
lastOrDefault
let | letBind
manySelect
map
max
maxBy
merge
mergeAll
min
minBy
multicast
observeOn
onErrorResumeNext
pairwise
partition
pausable
pausableBuffered
pluck
publish
publishLast
publishValue
share
shareReplay
shareValue
refCount
reduce
repeat
replay
retry
retryWhen
sample
scan
select
selectConcat
selectMany
selectManyObserver
selectSwitch
sequenceEqual
single
singleInstance
singleOrDefault
skip
skipLast
skipLastWithTime
skipUntil
skipUntilWithTime
skipWhile
some
startWith
subscribe | forEach
subscribeOn
sum
switch | switchLatest
take
takeLast
takeLastBuffer
takeLastBufferWithTime
takeLastWithTime
takeUntil
takeUntilWithTime
takeWhile
tap
tapOnNext
tapOnError
tapOnCompleted
timeInterval
timeout
timeoutWithSelector
timestamp
toArray
where
window
windowWithCount
windowWithTime
windowWithTimeOrCount
withLatestFrom
zip
Deprecated Observable Methods
Deprecated Observable Instance Methods
aggregate
all
any
doAction
catchException
concatObservable
contains
finallyAction
mergeObservable
throttle
throttleWithSelector