Home

Getting Started

Adding a dependency

Streaming

Performance

• Optimizing cyclops-react Streams

Plumbing Streams

• Queues explained
• Plumbing Streams with Queues, Topics and Signals
• Agrona wait free Queues

Backpressure

• Applying Backpressure across Streams

FutureStreams

• simple-react overview
• LazyFutureStream & reactive-streams
• A simple API (simple-react) and a rich api (LazyFutureStream
• Asynchronous terminal operations

Operators

• Batching, time control, sharding, zipping
• onFail
• Event based : forEachWithError etc

The tutorial (with videos)

• getting started
• [error handling]
• [filter /map/ reduce /flatMap]
• [choosing a stream type]
• [stream creation]
• [pooling reactors]
• [pull / push model]
• [flow control]
• [batching and chunking]
• [sharding]
• [zipping streams]
• [firstOf, anyOf, allOf]
• [stream operations]
• [sequence operations]

FutureStream concepts

Performance auto-optimization

• Automatic optimization

Performance : sync vs async

• Async vs sync future execution

Performance memoization (caching)

• Automemoize

Acting on Futures or Acting on Results

• Acting on Futures