We have collection of more than 1 Million open source products ranging from Enterprise product to small libraries in all platforms. We aggregate information from all open source repositories. Search and find the best for your needs. Check out projects section.
elastic4s - Elasticsearch Scala Client - Non Blocking, Type Safe, HTTP, TCP
Elastic4s is a concise, idiomatic, reactive, type safe Scala client for Elasticsearch. The client can be used over both HTTP and TCP by choosing either of the elastic4s-http or elastic4s-tcp submodules. The official Elasticsearch Java client can of course be used in Scala, but due to Java's syntax it is more verbose and it naturally doesn't support classes in the core Scala core library nor Scala idioms.Elastic4s's DSL allows you to construct your requests programatically, with syntactic and semantic errors manifested at compile time, and uses standard Scala futures to enable you to easily integrate into an asynchronous workflow. The aim of the DSL is that requests are written in a builder-like way, while staying broadly similar to the Java API or Rest API. Each request is an immutable object, so you can create requests and safely reuse them, or further copy them for derived requests. Because each request is strongly typed your IDE or editor can use the type information to show you what operations are available for any request type.
elasticsearch reactive-streams elasticsearch-client elasticsearch-libraryalpakka - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka
Systems don't come alone. In the modern world of microservices and cloud deployment, new components must interact with legacy systems, making integration an important key to success. Reactive Streams give us a technology-independent tool to let these heterogeneous systems communicate without overwhelming each other. The Alpakka project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Akka Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.
integration reactive akka akka-stream akka-streams-connectors reactive-streams messagingphantom - Schema safe, type-safe, reactive Scala driver for Cassandra/Datastax Enterprise
To stay up-to-date with our latest releases and news, follow us on Twitter: @outworkers. If you use phantom, please consider adding your company to our list of adopters. Phantom is and will always be open source, but the more adopters our projects have, the more people from our company will actively work to make them better.
phantom cassandra datastax-enterprise reactive reactive-streamsEasyReact - Are you confused by the functors, applicatives, and monads in RxSwift and ReactiveCocoa? It doesn't matter, the concepts are so complicated that not many developers actually use them in normal projects
EasyReact is an easy-to-use reactive programming framework. Are you confused by the functors, applicatives, and monads in RxSwift and ReactiveCocoa? It doesn't matter, the concepts are so complicated that not many developers actually use them in normal projects. Is there an easy-to-use way to use reactive programming? EasyReact is born for this reason.
objective-c-library reactive-programming reactive-streamsProject Reactor - Create efficient Reactive systems
Reactor is a fourth-generation Reactive library for building non-blocking applications on the JVM based on the Reactive Streams Specification. Reactor is a fully non-blocking foundation with efficient demand management. It directly interacts with Java functional API, Completable Future, Stream and Duration. Reactor Operators and Schedulers can sustain high throughput rates on the order of 10's of millions of messages per second.
reactive asynchronous async reactive-streams non-blocking rx-javareactor-core - Non-Blocking Reactive Foundation for the JVM
Non-Blocking Reactive Streams Foundation for the JVM both implementing a Reactive Extensions inspired API and efficient event streaming support. Reactor 3 requires Java 8 or + to run.
reactive flux mono reactive-streams flow asynchronous reactive-extensions jvmAlpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka
The Alpakka project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Akka Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.
kafka reactive-streams akka akka-streams reactive kafka-client kafka-connectorcyclops-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.
functional-programming reactive-streams monoid streams collections data-structures monad monad-transformers reactive asynchronous java8 streams-apiAutoDispose - Automatic binding+disposal of RxJava 2 streams.
AutoDispose is an RxJava 2 tool for automatically binding the execution of RxJava 2 streams to a provided scope via disposal/cancellation.Often (especially in mobile applications), Rx subscriptions need to stop in response to some event (for instance, when Activity#onStop() executes in an Android app). In order to support this common scenario in RxJava 2, we built AutoDispose.
uber autodispose rxjava reactive-extensions reactive-streams rxandroid android kotlin lifecycleRxJava2Interop - Library to convert between RxJava 1
Library to convert between RxJava 1.x and 2.x reactive types.Note that 2.x Subjects and FlowableProcessors support only the same input and output types.
rxjava extensions interoperation reactive-streamsTymeacRSE - 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.
reactive-streams reactive streams push-engine asynchronoussttp - The Scala HTTP client you always wanted!
sttp is an open-source library which provides a clean, programmer-friendly API to define HTTP requests and execute them using one of the wrapped backends, such as akka-http, async-http-client or OkHttp. sttp documentation is available at sttp.readthedocs.io.
http httpclient interpolator uri asynchronous synchronous akka-http monix scalaz reactive-streams okhttp catsspring-reactive-sample - Spring 5 Reactive playground
Reactive or Reactive Streams is a hot topic in these days, you can see it in blog entries, presentations, or some online course. Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure.This encompasses efforts aimed at runtime environments (JVM and JavaScript) as well as network protocols.
spring-webflux kotlin spring-boot reactive-streams spring-data spring-data-mongodb-reactive spring-data-redis spring-data-cassandra rxjava rxjava2 spring-security spring-session reactor springMutiny - An Intuitive Event-Driven Reactive Programming Library for Java
Mutiny places events at the core of its design. With Mutiny, you observe events, react to them, and create elegant and readable processing pipelines. Mutiny is the perfect companion to tame the asynchronous nature of applications with non-blocking I/O. Declaratively compose operations, transform data, enforce progress, recover from failures and more.
reactive asynchronous jvm reactive-streams streams reactive-extensions events event-driven libraryRxJava2Extensions - RxJava 2
RxJava 2.x implementation of extra sources, operators and components and ports of many 1.x companion libraries.Support the join-patterns and async-util with functional interfaces of consumers with 3-9 type arguments and have functional interfaces of functions without the throws Exception.
reactive-streams rxjava extensionsrxterm - Functional reactive terminals in C++ ⚡⌨️
A C++ library for functional-reactive terminals. RxTerm is a lean alternative to ncurses for many applications. The library builds with Buckaroo and either Buck or Bazel. It requires a C++ 14 compiler.
console reactive terminal cpp reactive-streams console-applicationbeicon - Reactive Streams for Clojure(Script)
Reactive Streams for Clojure(Script)
clojurescript rxjava rxjs reactive-programming reactive-streams rxjava2potok - Reactive streams based state management toolkit for ClojureScript
Potok is a tiny (100LOC) reactive streams based state management toolkit for ClojureScript.
reactive-streams reactive rxjs state-management react rum
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.
