Foreword
Introduction
1. Reactive Programming with RxJava
Reactive Programming and RxJava
When You Need Reactive Programming
How RxJava Works
Push versus Pull
Async versus Sync
Concurrency and Parallelism
Lazy versus Eager
Duality
Cardinality
Mechanical Sympathy: Blocking versus Nonblocking I/O
Reactive Abstraction
2. Reactive Extensions
Anatomy of rx.Observable
Subscribing to Notifications from Observable
Capturing All Notifications by Using Observer
Controlling Listeners by Using Subscription and Subscriber
Creating Observables
Mastering Observable.create0
Infinite Streams
Timing: timer() and interval()
Hot and Cold Observables
Use Case: From Callback API to Observable Stream
Manually Managing Subscribers
rx.subjects.Subject
ConnectableObservable
Single Subscription with publishO.refCountO
ConnectableObservable Lifecycle
Summary
3. Operators and Transformations
Core Operators: Mapping and Filtering
1-to-1 Transformations Using map()
Wrapping Up Using flatMap0
Postponing Events Using the delay() Operator
Order of Events After flatMap0
Preserving Order Using concatMap0
More Than One Observable
Treating Several Observables as One Using merge()
Pairwise Composing Using zip() and zipWith()
When Streams Are Not Synchronized with One Another: combineLatest(),
withLatestFrom(), and amb()
Advanced Operators: collect(), reduce(), scan(), distinct(), and groupBy()
Scanning Through the Sequence with Scan and Reduce
Reduction with Mutable Accumulator: collect()
Asserting Observable Has Exactly One Item Using single()
Dropping Duplicates Using distinct() and distinctUntilChanged()
Slicing and Dicing Using skip(), takeWhile(), and Others
Ways of Combining Streams: concat(), merge(), and switchOnNext()
