-
Notifications
You must be signed in to change notification settings - Fork 134
Home
johnmcclean-aol edited this page Nov 21, 2016
·
247 revisions
- Optimizing cyclops-react Streams
- Fast Futures and Fast Future Pooling : Fast Futures ~2.5 faster than CompletableFutures in LazyFutureStreams
- StreamSource for pushable 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
- 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
- Batching, time control, sharding, zipping
- onFail
- Event based : forEachWithError etc
- For comprehensions
- Retry
- Take, Skip and Sample
- Scheduling
- 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
- 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
- Understanding LazyFutureStreams behavior
- Quick overview of SimpleReactStream
- Understanding the push-pull model of FutureStreams
- FutureStream comparison matrix : note EagerFutureStream is discontinued
- React pools - elastic thread pools
- Fine Tuning SimpleReact
- Sharing a forkJoinPool with Parallel Streams - info purposes, don't do this!
- Separating task executors
oops - my bad