• 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.

$rootScope Methods:

  • $createObservableFunction
  • $toObservable
  • $eventToObservable