Reactive Programming

  1. Advanced Concepts
    1. Hot vs. Cold Observables
      1. Cold Observables (Unicast)
        1. Per-Subscriber Execution
          1. Use Cases
          2. Hot Observables (Multicast)
            1. Shared Execution
              1. Use Cases
              2. Converting Cold to Hot
                1. publish
                  1. Multicasting
                  2. share
                    1. Reference Counting
                    2. shareReplay
                      1. Caching Emissions
                  3. Subjects
                    1. Definition: The Hybrid Observable/Observer
                      1. Use Cases for Subjects
                        1. Event Buses
                          1. Multicasting
                            1. Bridging Imperative and Reactive Code
                            2. Types of Subjects
                              1. PublishSubject
                                1. Emitting to Current Subscribers
                                2. BehaviorSubject
                                  1. Emitting Latest Value to New Subscribers
                                  2. ReplaySubject
                                    1. Replaying Past Values
                                    2. AsyncSubject
                                      1. Emitting Only Last Value on Completion
                                  3. Backpressure
                                    1. The Problem: Fast Producer, Slow Consumer
                                      1. Data Overload
                                        1. Resource Exhaustion
                                        2. Backpressure Strategies
                                          1. Buffering
                                            1. Temporary Storage
                                            2. Dropping
                                              1. Discarding Excess Data
                                              2. Throttling/Sampling
                                                1. Reducing Emission Rate
                                                2. Erroring
                                                  1. Failing on Overload
                                              3. Marble Diagrams
                                                1. Visual Representation of Streams
                                                  1. Reading Marble Diagrams
                                                    1. Timeline Representation
                                                      1. Event Symbols
                                                        1. Operator Transformations
                                                        2. Creating Marble Diagrams
                                                          1. Documenting Stream Behavior
                                                            1. Communication Tool

                                                        Previous

                                                        3. Operators: The Language of Streams

                                                        Go to top

                                                        Next

                                                        5. Reactive Systems and Architectures