Home

Getting Started

• Adding cyclops-react dependency
• Adding the legacy cyclops-modules

Collections

• Working with persistent and mutable collections
• Lazy Extended Collections - Fast and powerful
• Extending JDK 8 Collections

Functions

• Working with Lambdas
• Memoization
• Partial Application
• Exception Softener
• Utilities for working with Functions
• Memoization, Currying, Uncurrying and Type inferencing

Pattern matching and the visitor pattern

• Pattern matching

Control Structures

Recursion

• Trampoline
• Trampolining: a practical guide for awesome Java Developers

Try / Maybe / FeatureToggle

• Try functional exception handling for Java 8
• Try examples
• When Functional Try outperforms Try / Catch
• Feature Toggling
• Maybe: A lazy tail-recursive version of Optional

Streaming

• Streaming overview : ReactiveSeq, Streamable and more

Performance

• Optimizing cyclops-react Streams
• Fast Futures and Fast Future Pooling : Fast Futures ~2.5 faster than CompletableFutures in LazyFutureStreams

Pushing data into Streams

• StreamSource for pushable Streams

Repeatable Streams (Streamable)

• Streamable
• Streamable as a mixin

Plumbing Streams

• Queues explained
• Signals explained
• Topics explained
• Plumbing Streams with Queues, Topics and Signals
• Agrona wait free Queues
• Wait strategies for working with Wait Free Queues

Backpressure

• Applying Backpressure across Streams

ReactiveSeq (powerful sequential Streaming)

• Scheduling Streams
• Asynchronous execution

FutureStreams

• LazyFutureStream overview : A powerful API for infinite parallel Streaming
• SimpleReactStream overview : an easy to use API for finite eager parellel Streaming
• 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
• For comprehensions
• Retry
• Take, Skip and Sample
• Scheduling

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

Examples

• Getting started example
• Building a non-blocking NIO Rest Client
• Bulk loading files
• Converting examples from RxJava
• Implementing a data cache
• Implementing a Quorum
• Reacting to asynchronous events with a Stream of CompletableFutures
• Selecting the fastest algorithm

FutureStream concepts

• Understanding LazyFutureStreams behavior
• Quick overview of SimpleReactStream
• Understanding the push-pull model of FutureStreams
• FutureStream comparison matrix : note EagerFutureStream is discontinued

Performance

• Automatic optimization
• Async vs sync future execution
• Automemoize

Acting on Futures or Acting on Results

• Operating on futures
• Acting on Futures

Configuration

• React pools - elastic thread pools
• Fine Tuning SimpleReact
• Sharing a forkJoinPool with Parallel Streams - info purposes, don't do this!
• Separating task executors