• 入门指南
  • Introduction
  • 为什么选择 RxJS
  • RxJS 设计指南
    • 简介
    • 什么时候该用 RxJS
    • RxJS的约定
    • 使用 RxJS
    • 操作实践
  • 开始 RxJS
    • 什么是 Reactive Extensions?
    • 探索RxJS的主要概念
    • 创建和查询可观察序列
      • 创建和订阅简单的可观察序列
      • 事件桥接
      • 回调桥接
      • Promises桥接
      • Generators 和 可观察序列
      • 查询可观察序列
      • 可观察序列中的错误处理
      • 可观察序列的Transducers
      • 可观察序列的Backpressure
      • 分类操作
    • Subjects
    • 调度和并发
    • 测试与调试
    • 实现你自己的操作符
  • 我该怎样选择操作符
    • 创建类操作符的选择
    • 实例操作符的选择
  • 如何实现...?
    • 如何包装现有的API?
    • 如何集成jQuery?
    • 如何集成Angular.js?
    • 如何创建简单的事件发射器?
  • 映射RxJS到不同的类库
    • 对于Bacon.js用户
    • 对于Async.js用户
  • API
  • config 全局配置
    • Promise
    • useNativeEvents
  • Helpers 工具函数
    • defaultComparer
    • defaultSubComparer
    • defaultError
    • identity
    • isPromise
    • noop
  • Observable 可观察对象
    • Observable 对象方法
      • amb
      • case
      • catch
      • combineLatest
      • concat
      • create
      • defer
      • empty
      • for | forIn
      • forkJoin
      • from
      • fromCallback
      • fromEvent
      • fromEventPattern
      • fromNodeCallback
      • fromPromise
      • generate
      • generateWithAbsoluteTime
      • generateWithRelativeTime
      • if
      • interval
      • isObservable
      • just | return
      • merge
      • mergeDelayError
      • never
      • of
      • ofWithScheduler
      • onErrorResumeNext
      • pairs
      • range
      • repeat
      • spawn
      • start
      • startAsync
      • throw
      • timer
      • toAsync
      • using
      • when
      • while | whileDo
      • wrap
      • zip
    • Observable 实例方法
      • amb
      • and
      • asObservable
      • average
      • buffer
      • bufferWithCount
      • bufferWithTime
      • bufferWithTimeOrCount
      • catch
      • combineLatest
      • concat
      • concatAll
      • concatMapObserver | selectConcatObserver
      • controlled
      • count
      • debounce
      • defaultIfEmpty
      • delay
      • delaySubscription
      • dematerialize
      • distinct
      • distinctUntilChanged
      • do | doAction | tap
      • doOnCompleted | tapOnCompleted
      • doOnError | tapOnError
      • doOnNext | tapOnNext
      • doWhile
      • elementAt
      • every
      • expand
      • extend | manySelect
      • filter | where
      • finally
      • find
      • findIndex
      • first
      • flatMap | selectMany
      • flatMapConcat | concatMap
      • flatMapFirst | selectSwitchFirst
      • flatMapLatest
      • flatMapObserver | selectManyObserver
      • flatMapWithMaxConcurrent
      • forkJoin
      • groupBy
      • groupByUntil
      • groupJoin
      • ignoreElements
      • includes
      • indexOf
      • isEmpty
      • join
      • jortSort
      • jortSortUntil
      • last
      • lastIndexOf
      • let | letBind
      • map | select
      • materialize
      • max
      • maxBy
      • merge
      • mergeAll
      • min
      • minBy
      • multicast
      • observeOn
      • onErrorResumeNext
      • pairwise
      • partition
      • pausable
      • pausableBuffered
      • pipe
      • pluck
      • publish
      • publishLast
      • publishValue
      • reduce
      • repeat
      • replay
      • retry
      • retryWhen
      • scan
      • sequenceEqual
      • share
      • shareReplay
      • shareValue
      • single
      • singleInstance
      • skip
      • skipLast
      • skipLastWithTime
      • skipUntil
      • skipUntilWithTime
      • skipWhile
      • skipWithTime
      • slice
      • some
      • startWith
      • subscribe | forEach
      • subscribeOn
      • subscribeOnCompleted
      • subscribeOnError
      • subscribeOnNext
      • sum
      • switch
      • switchFirst
      • take
      • takeLast
      • takeLastBuffer
      • takeLastBufferWithTime
      • takeLastWithTime
      • takeUntil
      • takeUntilWithTime
      • takeWhile
      • takeWithTime
      • thenDo
      • throttle
      • throttleLatest | sample
      • timeInterval
      • timeout
      • timestamp
      • toArray
      • toMap
      • toPromise
      • toSet
      • transduce
      • window
      • windowWithCount
      • windowWithTime
      • windowWithTimeOrCount
      • withLatestFrom
      • zip
      • zipIterable
  • Observer 观察者
    • Observer 对象方法
      • create
      • fromNotifier
    • Observer 实例方法
      • asObserver
      • checked
      • notifyOn
      • onCompleted
      • onError
      • onNext
      • toNotifier
  • Notification 通知
    • Notification 对象方法
      • createOnNext
      • createOnError
      • createOnCompleted
    • Notification 实例方法
      • accept
      • toObservable
    • Notification 原型
      • exception
      • hasValue
      • kind
      • value
  • Subjects
    • Rx.AsyncSubject
    • Rx.BehaviorSubject
    • Rx.ReplaySubject
    • Rx.Subject
  • Schedulers 调度器
    • Rx.HistoricalScheduler
    • Rx.Scheduler
    • Rx.VirtualTimeScheduler
  • Disposables 销毁
    • Rx.CompositeDisposable
    • Rx.Disposable
    • Rx.RefCountDisposable
    • Rx.SerialDisposable
    • Rx.SingleAssignmentDisposable
  • Testing 测试
    • Rx.ReactiveTest
    • Rx.Recorded
    • Rx.Subscription
    • Rx.TestScheduler
  • Bindings 绑定
    • DOM
      • Ajax
      • JSONP
      • Web Sockets
      • Web Workers
      • Mutation Observers
      • Geolocation
      • Schedulers
    • jQuery
    • AngularJS
      • Factories
        • rx
        • observeOnScope
      • Observable Methods
        • safeApply
      • $rootScope Methods
        • $toObservable
        • $eventToObservable
        • $createObservableFunction
    • Facebook React
    • Ractive.js
    • Node.js
      • Callback Handlers
        • fromCallback
        • fromNodeCallback
      • Event Handlers
        • fromEvent
        • toEventEmitter
      • Stream Handlers
        • fromStream
        • fromReadableStream
        • fromWritableStream
        • fromTransformStream
        • writeToStream
  • 资源
  • 资源
    • 文章
    • 相关响应式类库
      • Bacon
      • Cycle
      • Elm
      • Flyd
      • Kefir
      • RxJS
      • Most
    • 演讲
    • 视频
  • Recipes
  • 相关库的方法集合
    • rx.aggregates
    • rx.async
    • rx.backpressure
    • rx.binding
    • rx.coincidence
    • rx.complete
    • rx.experimental
    • rx.joinpatterns
    • rx.lite.extras
    • rx.lite
    • rx
    • rx.testing
    • rx.time
    • rx.virtualtime
  • Published with GitBook

Node.js

Node.js

  • Callback Handlers
    • fromCallback
    • fromNodeCallback
  • Event Handlers
    • fromEvent
    • toEventEmitter
  • Stream Handlers
    • fromStream
    • fromReadableStream
    • fromWritableStream
    • fromTransformStream
    • writeToStream