Skip to content

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

Sign in

Sign up

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

aol / cyclops Public

Notifications You must be signed in to change notification settings
Fork 136
Star 1.3k

Code
Issues 24
Pull requests 5
Actions
Projects
Wiki
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights

X Vector

Jump to bottom

cfinerty edited this page Nov 14, 2018 · 2 revisions

oops

oops - my bad

Toggle table of contents Pages 125

Home
A simple API, and a Rich API
Acting on Futures (actOnFutures operator)
Adding cyclops react as a dependency
Agrona Wait Free Queues
AnyM
async and sync execution
Asynchronous terminal operations
Automatic Optimization [autoOptimize]
autoMemoize (automatic caching)
Backup old readme.md
Batching, Time Control, Sharding and Zipping Operators
Benchmark for SimpleReact
Clojure and cyclops collections
CompletableFutures
CompletableFutureT
Custom operators and type conversions
Dexx and cyclops collections
Documentation and Presentations
EagerFutureStream
EagerFutureStream operations on underlying Futures
Error handling with onFail
Eval
Example : Building a non blocking NIO rest client
Example : Bulk loading files
Example : Converting examples from RxJava
Example : Implementing a data cache
Example : Implementing a Quorum
Example : Reacting to Asynchronous Events with a Stream of CompletableFutures
Example : Selecting the fastest algorithm result
FastFutures and FastFuture Pooling
Feature comparison matrix
Fine tuning SimpleReact
For
for comprehensions within a Stream
For operators
FutureW
FutureWT
Getting started with a simple example
Home3
Incremental Parallel Reduction
Infinite Streams in SimpleReact
Interoperability
Ior
JavaSlang and cyclops collections
JDK 8 Reactive Streams
LazyFutureStream
LazyFutureStream operations on underlying futures
Licensing
List of operators where EagerFutureStream batches results
ListT
ListX
Matchables
Maybe
MaybeT
Meet the team
Monoids & Semigroups
Old Wiki Home
Optionals
OptionalT
Pattern Matching Within a Stream
Pipes : an event bus
Predicates
Project goals
Queues explained
Reactive 'plugin' for easier use
Reactive Streams : ValueSubscriber
Reactive Tasks : reactive streams based operators
ReactiveStreams : QueueBasedSubscriber
ReactiveStreams : SeqSubscriber
ReactPools
Reader : functional dependency injection
Retry functionality in SimpleReact
Scala & cyclops collections
Scheduling Streams
Separating Task Executors
Setting up a development environment for SimpleReact
Sharing a ForkJoinPool with ParallelStreams
Signals Explained
simple react streams overview
SimpleReact overview
StreamSource
Take, Skip and Sample
Topics Explained
Type Interfaces : ApplicativeFunctor
Type Interfaces : BiFunctor
Type Interfaces : Combiner
Type Interfaces : EmptyUnit
Type Interfaces : Filterable
Type Interfaces : Foldable
Type Interfaces : Functor
Type Interfaces : HotStream
Type Interfaces : MonadicValue
Type Interfaces : MonadicValue1
Type Interfaces : MonadicValue2
Type Interfaces : PausableHotStream
Type Interfaces : ReactiveTask
Type Interfaces : To
Type Interfaces : Traversable
Type Interfaces : Unit
Type Interfaces : Value
Type Interfaces : Visitable
Type Interfaces : Zippable
Understanding LazyFutureStreams behaviour
Understanding the pull push model of simple react
Validator
Wait Strategies for working with Wait Free Queues
What does SimpleReact do?
When to use ParallelStreams and when to use SimpleReact
Working with Primitives in Streams
X Control Structures
X Eval
X extracting values
X Folding
X For comprehensions
X futurestreams
X LazySeq
X Managed
X Maybe
X NonEmptyList
X Option
X Persistent Collections
X Seq
X Vector
Xor

Clone this wiki locally

Footer

Footer navigation

Terms
Privacy
Security
Status
Docs
Contact

You can’t perform that action at this time.