Downloaded 20 times
Reactive Programming and RxJS
- 1. Reactive Programming and RxJS byDenis Gorbunov
- 2. In computing, reactiveprogramming is a programming paradigm oriented around data flows and the propagation of change. wikipedia.org
- 3. Systems built asReactive Systems are more flexible, loosely-coupled and scalable. This makes them easier to develop and amenable to change. They are significantly more tolerant of failure and when failure does occur they meet it with elegance rather than disaster. Reactive Systems are highly responsive, giving users effective interactive feedback. reactivemanifesto.org
- 13. reactivex.io Java: RxJava JavaScript: RxJS C#:Rx.NET C#(Unity): UniRx Scala: RxScala Clojure: RxClojure C++: RxCpp Ruby: Rx.rb Python: RxPY Groovy: RxGroovy JRuby: RxJRuby Kotlin: RxKotlin Swift: RxSwift PHP: RxPHP
- 14. reactivex.io Java: RxJava JavaScript: RxJS C#:Rx.NET C#(Unity): UniRx Scala: RxScala Clojure: RxClojure C++: RxCpp Ruby: Rx.rb Python: RxPY Groovy: RxGroovy JRuby: RxJRuby Kotlin: RxKotlin Swift: RxSwift PHP: RxPHP
- 15. ReactiveX is acombination of the best ideas from the Observer pattern, the Iterator pattern, and functional programming reactivex.io
- 16.
- 22. RxJS: Operators ReactiveX providesa collection of operators with which you can filter, select, transform, combine, and compose Observables. This allows for efficient execution and composition.
- 23. RxJS: Operators • buffer •bufferCount • bufferTime • bufferToggle • bufferWhen • cache • catch • combineAll • combineLatest • concat • concatAll • concatMap • concatMapTo • create • debounce • debounceTime • defaultIfEmpty • distinctUntilCha nged • delay • delayWhen • do • every • empty • expand • filter • first • forkJoin • from • fromEvent • fromPromise • groupBy • ignoreElements • interval • last • let • map • mapTo • merge • mergeAll • mergeMap
- 24. RxJS: Operators • multicast •of • partition • pluck • publish • race • range • retry • retryWhen • sample • share • single • skip • skipUntil • skipWhile • startWith • take • takeUntil • takeWhile • throttle • throttleTime • throw • timer • toPromise • scan • switchMap • window • windowCount • windowTime • windowToggle • windowWhen • withLatestFrom • zip
- 25.
- 27.
- 30.
- 32.
- 34.
- 37.
- 38.
- 39.
- 40.
- 41.
- 42.
- 43.
- 44.
- 45.
- 46.
- 47.
- 48.
- 49. Hot and ColdObservables medium.com/@benlesh Observables are functions that tie an observer to a producer.
- 50. RxJS: Observable andObserver
- 51. Hot and ColdObservables COLD is when your observable creates the producer medium.com/@benlesh
- 52. Hot and ColdObservables COLD is when your observable creates the producer HOT is when your observable closes over the producer medium.com/@benlesh
- 53. Hot and ColdObservables COLD is when your observable creates the producer HOT is when your observable closes over the producer medium.com/@benlesh
- 54.
- 55. Unsubscribe medium.com/@benlesh • take(n): emitsN values before stopping the observable. • takeWhile(predicate): tests the emitted values against a predicate, if it returns `false`, it will complete. • first(): emits the first value and completes. • first(predicate): checks each value against a predicate function, if it returns `true`, the emits that value and completes.