Introduction
1.
Why RxJS?
2.
RxJS Design Guidelines
2.1.
Introduction
2.2.
When To Use RxJS
2.3.
The RxJS Contract
2.4.
Using RxJS
2.5.
Operator Implementations
3.
Getting Started With RxJS
3.1.
What Are The Reactive Extensions?
3.2.
Exploring Major Concepts In RxJS
3.3.
Creating And Querying Observable Sequences
3.3.1.
Creating And Subscribing To Simple Observable Sequences
3.3.2.
Bridging To Events
3.3.3.
Bridging To Callbacks
3.3.4.
Bridging To Promises
3.3.5.
Generators And Observable Sequences
3.3.6.
Querying Observable Sequences
3.3.7.
Error Handling With Observable Sequences
3.3.8.
Transducers With Observable Sequences
3.3.9.
Backpressure With Observable Sequences
3.3.10.
Operators By Category
3.4.
Subjects
3.5.
Scheduling And Concurrency
3.6.
Testing And Debugging
3.7.
Implementing Your Own Operators
4.
How Do I...?
4.1.
How Do I Wrap An Existing API?
4.2.
How Do I Integrate jQuery With RxJS?
4.3.
How Do I Integrate Angular.js With RxJS?
4.4.
How Do I Create A Simple Event Emitter?
5.
Mapping RxJS From Different Libraries
5.1.
For Bacon.js Users
5.2.
For Async.js Users
6.
Config
6.1.
Promise
6.2.
useNativeEvents
7.
Helpers
7.1.
defaultComparer
7.2.
defaultSubComparer
7.3.
defaultError
7.4.
identity
7.5.
just
7.6.
isPromise
7.7.
noop
7.8.
pluck
8.
Observable
8.1.
Observable Methods
8.1.1.
amb
8.1.2.
case
8.1.3.
catch
8.1.4.
combineLatest
8.1.5.
concat
8.1.6.
create
8.1.7.
defer
8.1.8.
empty
8.1.9.
for | forIn
8.1.10.
forkJoin
8.1.11.
from
8.1.12.
fromCallback
8.1.13.
fromEvent
8.1.14.
fromEventPattern
8.1.15.
fromNodeCallback
8.1.16.
fromPromise
8.1.17.
generate
8.1.18.
generateWithAbsoluteTime
8.1.19.
generateWithRelativeTime
8.1.20.
if
8.1.21.
interval
8.1.22.
isObservable
8.1.23.
just | return
8.1.24.
merge
8.1.25.
mergeDelayError
8.1.26.
never
8.1.27.
of
8.1.28.
ofWithScheduler
8.1.29.
onErrorResumeNext
8.1.30.
pairs
8.1.31.
range
8.1.32.
repeat
8.1.33.
spawn
8.1.34.
start
8.1.35.
startAsync
8.1.36.
throw
8.1.37.
timer
8.1.38.
toAsync
8.1.39.
using
8.1.40.
when
8.1.41.
while | whileDo
8.1.42.
wrap
8.1.43.
zip
8.2.
Observable Instance Methods
8.2.1.
amb
8.2.2.
and
8.2.3.
asObservable
8.2.4.
average
8.2.5.
buffer
8.2.6.
bufferWithCount
8.2.7.
bufferWithTime
8.2.8.
bufferWithTimeOrCount
8.2.9.
catch
8.2.10.
combineLatest
8.2.11.
concat
8.2.12.
concatAll
8.2.13.
concatMapObserver | selectConcatObserver
8.2.14.
controlled
8.2.15.
count
8.2.16.
debounce
8.2.17.
defaultIfEmpty
8.2.18.
delay
8.2.19.
delaySubscription
8.2.20.
dematerialize
8.2.21.
distinct
8.2.22.
distinctUntilChanged
8.2.23.
do | doAction | tap
8.2.24.
doOnCompleted | tapOnCompleted
8.2.25.
doOnError | tapOnError
8.2.26.
doOnNext | tapOnNext
8.2.27.
doWhile
8.2.28.
elementAt
8.2.29.
every
8.2.30.
expand
8.2.31.
extend | manySelect
8.2.32.
filter | where
8.2.33.
finally
8.2.34.
find
8.2.35.
findIndex
8.2.36.
first
8.2.37.
flatMap | selectMany
8.2.38.
flatMapConcat | concatMap
8.2.39.
flatMapFirst | selectSwitchFirst
8.2.40.
flatMapLatest
8.2.41.
flatMapObserver | selectManyObserver
8.2.42.
flatMapWithMaxConcurrent
8.2.43.
forkJoin
8.2.44.
groupBy
8.2.45.
groupByUntil
8.2.46.
groupJoin
8.2.47.
ignoreElements
8.2.48.
includes
8.2.49.
indexOf
8.2.50.
isEmpty
8.2.51.
join
8.2.52.
jortSort
8.2.53.
jortSortUntil
8.2.54.
last
8.2.55.
lastIndexOf
8.2.56.
let | letBind
8.2.57.
map | select
8.2.58.
materialize
8.2.59.
max
8.2.60.
maxBy
8.2.61.
merge
8.2.62.
mergeAll
8.2.63.
min
8.2.64.
minBy
8.2.65.
multicast
8.2.66.
observeOn
8.2.67.
onErrorResumeNext
8.2.68.
pairwise
8.2.69.
partition
8.2.70.
pausable
8.2.71.
pausableBuffered
8.2.72.
pipe
8.2.73.
pluck
8.2.74.
publish
8.2.75.
publishLast
8.2.76.
publishValue
8.2.77.
reduce
8.2.78.
repeat
8.2.79.
replay
8.2.80.
retry
8.2.81.
retryWhen
8.2.82.
scan
8.2.83.
sequenceEqual
8.2.84.
share
8.2.85.
shareReplay
8.2.86.
shareValue
8.2.87.
single
8.2.88.
singleInstance
8.2.89.
skip
8.2.90.
skipLast
8.2.91.
skipLastWithTime
8.2.92.
skipUntil
8.2.93.
skipUntilWithTime
8.2.94.
skipWhile
8.2.95.
skipWithTime
8.2.96.
slice
8.2.97.
some
8.2.98.
startWith
8.2.99.
subscribe | forEach
8.2.100.
subscribeOn
8.2.101.
subscribeOnCompleted
8.2.102.
subscribeOnError
8.2.103.
subscribeOnNext
8.2.104.
sum
8.2.105.
switch
8.2.106.
switchFirst
8.2.107.
take
8.2.108.
takeLast
8.2.109.
takeLastBuffer
8.2.110.
takeLastBufferWithTime
8.2.111.
takeLastWithTime
8.2.112.
takeUntil
8.2.113.
takeUntilWithTime
8.2.114.
takeWhile
8.2.115.
takeWithTime
8.2.116.
thenDo
8.2.117.
throttle
8.2.118.
throttleLatest | sample
8.2.119.
timeInterval
8.2.120.
timeout
8.2.121.
timestamp
8.2.122.
toArray
8.2.123.
toMap
8.2.124.
toPromise
8.2.125.
toSet
8.2.126.
transduce
8.2.127.
window
8.2.128.
windowWithCount
8.2.129.
windowWithTime
8.2.130.
windowWithTimeOrCount
8.2.131.
withLatestFrom
8.2.132.
zip
8.2.133.
zipIterable
9.
Observer
9.1.
Observer Methods
9.1.1.
create
9.1.2.
fromNotifier
9.2.
Observer Instance Methods
9.2.1.
asObserver
9.2.2.
checked
9.2.3.
notifyOn
9.2.4.
onCompleted
9.2.5.
onError
9.2.6.
onNext
9.2.7.
toNotifier
10.
Notification
10.1.
Notification Methods
10.1.1.
createOnNext
10.1.2.
createOnError
10.1.3.
createOnCompleted
10.2.
Notification Instance Methods
10.2.1.
accept
10.2.2.
toObservable
10.3.
Notification Properties
10.3.1.
exception
10.3.2.
hasValue
10.3.3.
kind
10.3.4.
value
11.
Subjects
11.1.
Rx.AsyncSubject
11.2.
Rx.BehaviorSubject
11.3.
Rx.ReplaySubject
11.4.
Rx.Subject
12.
Schedulers
12.1.
Rx.HistoricalScheduler
12.2.
Rx.Scheduler
12.3.
Rx.VirtualTimeScheduler
13.
Disposables
13.1.
Rx.CompositeDisposable
13.2.
Rx.Disposable
13.3.
Rx.RefCountDisposable
13.4.
Rx.SerialDisposable
13.5.
Rx.SingleAssignmentDisposable
14.
Testing
14.1.
Rx.ReactiveTest
14.2.
Rx.Recorded
14.3.
Rx.Subscription
14.4.
Rx.TestScheduler
15.
Bindings
15.1.
DOM
15.1.1.
Ajax
15.1.1.1.
ajax
15.1.1.2.
ajaxCold
15.1.1.3.
get
15.1.1.4.
get_Json
15.1.1.5.
post
15.1.2.
JSONP
15.1.2.1.
jsonpRequest
15.1.2.2.
jsonpRequestCold
15.1.3.
Web Sockets
15.1.3.1.
fromWebSocket
15.1.4.
Web Workers
15.1.4.1.
fromWebWorker
15.1.5.
Mutation Observers
15.1.5.1.
fromMutationObserver
15.1.6.
Geolocation
15.1.6.1.
getCurrentPosition
15.1.6.2.
watchPosition
15.1.7.
Schedulers
15.1.7.1.
requestAnimationFrame
15.1.7.2.
mutationObserver
15.2.
jQuery
15.3.
AngularJS
15.3.1.
Factories
15.3.1.1.
rx
15.3.1.2.
observeOnScope
15.3.2.
Observable Methods
15.3.2.1.
safeApply
15.3.3.
$rootScope Methods
15.3.3.1.
$toObservable
15.3.3.2.
$eventToObservable
15.3.3.3.
$createObservableFunction
15.4.
Facebook React
15.5.
Ractive.js
15.6.
Node.js
15.6.1.
Callback Handlers
15.6.1.1.
fromCallback
15.6.1.2.
fromNodeCallback
15.6.2.
Event Handlers
15.6.2.1.
fromEvent
15.6.2.2.
toEventEmitter
15.6.3.
Stream Handlers
15.6.3.1.
fromStream
15.6.3.2.
fromReadableStream
15.6.3.3.
fromWritableStream
15.6.3.4.
fromTransformStream
15.6.3.5.
writeToStream
16.
Resources
16.1.
Articles
16.2.
Reactive Libraries
16.2.1.
Bacon
16.2.2.
Cycle
16.2.3.
Elm
16.2.4.
Flyd
16.2.5.
Kefir
16.2.6.
RxJS
16.2.7.
Most
16.3.
Presentations
16.4.
Video
17.
Recipes
18.
Which Operator do I use?
18.1.
Creation Operators
18.2.
Instance Operators
Published with GitBook
RxJS - Javascript library for functional reactive programming.
RxJS Design Guidelines
Introduction
When to use RxJS
Use RxJS for orchestrating asynchronous and event-based computations
Use RxJS to deal with asynchronous sequences of data
The RxJS contract
Assume the RxJS Grammar
Assume resources are cleaned up after an
onError
or
onCompleted
messages
Assume a best effort to stop all outstanding work on Unsubscribe
Using RxJS
Operator implementations
