Streams

Streams

Introduction
- Motivation
- How to read these docs
Quick Start Guide
- Reusable Pieces
- Time-Based Processing
Reactive Tweets
- Transforming and consuming simple streams
- Flattening sequences in streams
- Broadcasting a stream
- Back-pressure in action
- Materialized values
Design Principles behind Akka Streams
- What shall users of Akka Streams expect?
- Interoperation with other Reactive Streams implementations
- What shall users of streaming libraries expect?
- The difference between Error and Failure
Basics and working with Flows
- Core concepts
- Defining and running streams
- Back-pressure explained
- Stream Materialization
- Stream ordering
Working with Graphs
- Constructing Graphs
- Constructing and combining Partial Graphs
- Constructing Sources, Sinks and Flows from Partial Graphs
- Combining Sources and Sinks with simplified API
- Bidirectional Flows
- Accessing the materialized value inside the Graph
- Graph cycles, liveness and deadlocks
Modularity, Composition and Hierarchy
- Basics of composition and modularity
- Composing complex systems
- Materialized values
- Attributes
Buffers and working with rate
- Buffers for asynchronous stages
- Buffers in Akka Streams
- Rate transformation
Dynamic stream handling
- Controlling graph completion with KillSwitch
- Dynamic fan-in and fan-out with MergeHub and BroadcastHub
Custom stream processing
- Custom processing with GraphStage
- Thread safety of custom processing stages
Integration
- Integrating with Actors
- Integrating with External Services
- Integrating with Reactive Streams
Error Handling
- Supervision Strategies
- Errors from mapAsync
Working with streaming IO
- Streaming TCP
- Streaming File IO
Pipelining and Parallelism
- Pipelining
- Parallel processing
- Combining pipelining and parallel processing
Testing streams
- Built in sources, sinks and combinators
- TestKit
- Streams TestKit
Overview of built-in stages and their semantics
- Source stages
- Sink stages
- Additional Sink and Source converters
- File IO Sinks and Sources
- Flow stages
- Simple processing stages
- Asynchronous processing stages
- Timer driven stages
- Backpressure aware stages
- Nesting and flattening stages
- Time aware stages
- Fan-in stages
- Fan-out stages
- Watching status stages
Streams Cookbook
- Introduction
- Working with Flows
- Working with Graphs
- Working with rate
- Working with IO
Configuration
Migration Guide 1.0 to 2.x
Migration Guide 2.0.x to 2.4.x
- General notes
- Changed Operators
- Changed Sources / Sinks
- PushStage, PushPullStage and DetachedStage have been deprecated in favor of GraphStage
- Changes in Akka HTTP

Contents