Related Projects

cyclops-react - An advanced, but easy to use, platform for writing functional applications in Java 8


Powerful Streams and functional data types for building modern Java 8 applications. We extend JDK interfaces where possible for maximum integration.ReactiveSeq extends JDK Stream and offers multiple modes of execution - synchonous, asynchronous, asynchronous with backpressure, parallel and more.

TymeacRSE - Java Reactive Streams Push Engine


TymeacRSE is a Recursive Streams push engine for managing the publication and distribution of items to subscribers. An efficient push engine allowing (Reactive Stream) Publishers to generate asynchronous streams for routing to Subscribers. It provides an efficient multitasking service that allows many resource-intensive applications to coexist in a single microservice.



Monix - Asynchronous Programming for Scala and Scala.js


Monix is a high-performance Scala / Scala.js library for composing asynchronous and event-based programs, exposing high-level types, such as observable sequences that are exposed as asynchronous streams, expanding on the observer pattern, strongly inspired by ReactiveX and by Scalaz, but designed from the ground up for back-pressure and made to cleanly interact with Scala’s standard library, compatible out-of-the-box with the Reactive Streams protocol.

toketi-iothubreact - Akka Stream library for Azure IoT Hub


IoTHub React is an Akka Stream library that can be used to read events from Azure IoT Hub, via a reactive stream with asynchronous back pressure, and to send commands to connected devices. Azure IoT Hub is a service used to connect thousands to millions of devices to the Azure cloud.The library can be used both in Java and Scala, providing a fluent DSL for both programming languages, similarly to the approach used by Akka.

jonas - Monad and Reactive programming for JavaScript, leveraging Q promises


Monad and Reactive programming for JavaScript, leveraging Q promises

activator-akka-stream-java8 - Demonstrate Akka streams in Java8


Demonstrate Akka streams in Java8.Akka Streams is an implementation of Reactive Streams, which is a standard for asynchronous stream processing with non-blocking backpressure.

reactive-stream - reactive-stream - Reactive programming with JDK 8


reactive-stream - Reactive programming with JDK 8

Redisson - Redis based In-Memory Data Grid for Java


Redisson - distributed Java objects and services (Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, Map Reduce, Publish / Subscribe, Bloom filter, Spring Cache, Executor service, Tomcat Session Manager, Scheduler service, JCache API) on top of Redis server. Rich Redis client.

samsara - Reactive layout for user interfaces


SamsaraJS is a functional reactive library for animating layout. It provides a language for positioning, orienting and sizing DOM elements and animating these properties over time. Everything in SamsaraJS — from the user input to the rendering pipeline — is a stream. Building a user interface becomes the art of composing streams.

activator-akka-stream-scala - Demonstrate Akka streams in Scala


Demonstrate Akka streams in Scala.Akka Streams is an implementation of Reactive Streams, which is a standard for asynchronous stream processing with non-blocking backpressure.

promise-stream - A Promises/A implementation based on streams


A Promises/A implementation based on streams