RxJava
Reactive Streams
Our great sponsors
RxJava | Reactive Streams | |
---|---|---|
15 | 16 | |
47,597 | 4,736 | |
0.3% | 0.4% | |
8.4 | 1.9 | |
1 day ago | 16 days ago | |
Java | Java | |
Apache License 2.0 | MIT No Attribution |
Stars - the number of stars that a project has on GitHub. Growth - month over month growth in stars.
Activity is a relative number indicating how actively a project is being developed. Recent commits have higher weight than older ones.
For example, an activity of 9.0 indicates that a project is amongst the top 10% of the most actively developed projects that we are tracking.
RxJava
-
Humble Chronicles: Managing State with Signals
Is this similar RxJava, the reactive extensions library for https://github.com/ReactiveX/RxJava ? I have made that work in Clojure in production.
-
How to do threading in Android.
Since you mentioned java, there is RxJava and RxAndroid. Google general recommendation now is to use kotlin coroutines if you're considering writing your app with that.
-
must known frameworks/libs/tech, every senior java developer must know(?)
You all beat me to MapStruct and Testcontainers. Honorable mention to RxJava, which I use in Desktop apps.
-
What is your tech stack?
RxJava with RxRelay (and rx-combinetuple-kt)
-
Best libraries for Android Developers
RxJava2
-
What are the most common used (3rd party) libraries and frameworks used in Android development?
Concurrency: Kotlin coroutines for general use, Rx or Flow for reactive programming (you can technically use Rx for regular concurrency as well, but not really what it's meant for)
-
When consuming from a reactive stream is it more like a literal stream where items in the stream ay go by and not get consumed while you're busy, or is it more like a queue?
In big words, kafka and rxJava are 2 different things, with kafka you transport data, produce and consume messages, then you can process them however you want. Rx java helps you write asynchronous code and it's no queue/topic related. You can read more here
- MVVM Architecture On HarmonyOS Using Retrofit And RxJava
-
Backpressure in Reactive Systems
This post provides information on backpressure in general and how RxJava (v3), Project Reactor and Kotlin's Coroutines handle it.
-
Functional Programming in Java, Explained
Both of the most popular Java Reactive libraries, RxJava and Reactor, are based on Java 8 Streams API, which means they also use functional interfaces in their code.
Reactive Streams
-
Reactive Backend Applications with Spring Boot, Kotlin and Coroutines (Part 1)
Reactive programming is a paradigm that focuses on non-blocking and asynchronous processing of tasks. One set of specifications/abstractions for reactive programming on JVM is called Reactive Streams. Project Reactor is a message-driven, type-safe and functional implementation of Reactive Streams, and it is used by Spring (via spring-webflux module) to enable reactive web applications. Reactive streams model the data processing as a stream with one end producing the values and one end consuming them.
-
Brief Intro to Reactive Streams with Project Reactor
The reactive streams API provides the specification for non-blocking async streams processing with back pressure mechanism, and Project Reactor is an implementation written in java.
-
Cosmos DB for Spring Developers, Part I: Using Cosmos DB as a SQL Database
NOTE: The Reactive Streams API and the implementation of it as provided by Spring WebFlux/Project Reactor is beyond the scope of this particular article. Please consult the appropriate documentation at the 'Web on Reactive Stack' Spring documentation site, any of several sessions I've delivered available on my YouTube channel, or by visiting the Reactive Streams and Project Reactor sites.
-
Show HN: Pidove, an Alternative to the Java Streams API
There is a very big design space for "Stream" APIs.
Microsoft's LINQ for instance can compile a stream operation into a SQL statement and JooQ does the same. That system offers query optimization and efficient joins that depend on the query system having complete visibility into the queries. indexes built ahead of time, etc.
Another extreme is a system like
https://www.reactive-streams.org/
that are especially good for apply a filter and map and other operations to a stream of real time events, e.g. instead of having a pull operation such as a for-loop over an Iterable, items go into the system from a stream.
I've worked on systems that use the later kind of streaming to run batch jobs and you can get great performance (780% speedup with 8 cpus) on crazy heterogenous workloads. You do have to be careful though to shut the system down or flush it out or otherwise you get wrong answers. Frequently those frameworks don't shut themselves down properly unless you implement clean shutdown yourself.
The point is that operators like "filter" and "map" and the rest are so powerful because they are portable between the minimal pidove up to a Hadoop cluster.
-
What is the current state of the art for efficiently handling blocking requests in Java/Spring?
Reactive libraries like reactor are build on the Reactive Streams specification, just read that first sentence.
- When consuming from a reactive stream is it more like a literal stream where items in the stream ay go by and not get consumed while you're busy, or is it more like a queue?
-
Are there any good tutorials showing the use of Reactor streams using Kotlin?
Kotlin Coroutines also implements the Reactive Streams spec, and I think it has some interop features to convert from coroutine objects to either Reactor or RxJava as well.
-
Backpressure in Reactive Systems
-- Reactive Streams specifications for the JVM
Whether based on reactivestreams.org or Java's java.util.concurrent.Flow, Reactive Streams provides four building blocks
-
Async await in Java
You can go all in on "Reactive programming", more infos: Reactive Streams (spec), Spring Reactor, RxJava
What are some alternatives?
Mutiny - An Intuitive Event-Driven Reactive Programming Library for Java
Reactor
Vert.x - Vert.x is a tool-kit for building reactive applications on the JVM
EventBus - Event bus for Android and Java that simplifies communication between Activities, Fragments, Threads, Services, etc. Less code, better quality.
RxAndroid - RxJava bindings for Android
otto
reactor-core - Non-Blocking Reactive Foundation for the JVM
rsocket-java - Java implementation of RSocket
ea-async - EA Async implements async-await methods in the JVM.