From Reactive Extensions to Reactive Streams

Explore the evolution of declarative workflows in this comprehensive conference talk, starting from Rx.NET observables and async enumerables, and tracing their development into the multi-platform standard known as reactive streams. Delve into the internals of Akka.NET streams, an implementation of this standard, and discover how streams can be utilized as universal building blocks across various domains, including networking and event sourcing. Learn about API vs SP tradeoffs, design decisions in reactive extensions, limitations of async enumerables, and the publish-subscribe model. Examine concepts such as dynamic push-pull demand, materialization processes, and the interpreter pattern. Gain insights into server-side extensions, flow synchronization, and persistence through practical demonstrations and examples, including a beautiful flowgraph DSL.

Introduction
Controversial ideas
Outline
API vs SP
Tradeoffs
API based libraries
SPI
Design Decisions
Reactive Extensions
Async enumerable
Async continuation
Publishsubscribe model
Limitations
NARS
Tasks
Slow continuation
Batching
Sideline
Dynamic PushPull
Demand
The Magic
Syncing
Task
AirSocket
Test Compatibility Kit
Service Provider Interface
Server Side Extensions
Source Flow Sync
Demo
Materialization Process
Interpreter Pattern
Materialization
Reactive Stream IO
byte strings
beautiful flow
graph DSL example
Persistence
Simple Actor
Stream Rep