The article examines Project Loom's virtual threads, compares them with reactive streams, explores their underlying mechanisms, presents a direct‑style flow library (Jox) that combines both paradigms, and evaluates performance, backpressure, and error handling in Java concurrency.
This tutorial demonstrates how to use Spring WebFlux’s reactive streaming to create a ChatGPT‑like typing effect, covering backend setup, SSE integration, frontend Axios handling, and a comparison between Flux and traditional Server‑Sent Events.
This article explains the concept of data streams, compares pull and push processing models, discusses flow‑control and backpressure mechanisms, evaluates queue choices, and details the core Reactive Streams interfaces (Publisher, Subscriber, Subscription) with example code and references to popular libraries.
The article shows how a unified abstraction called statefulMap, together with a resource‑aware mapWithResource primitive, lets developers implement a wide range of complex reactive‑stream operators—such as buffering, indexing, deduplication, and safe DB access—in a concise, composable, thread‑safe manner, dramatically reducing boilerplate code.
The seventh Scala Meetup gathered over 1400 online participants to share three technical talks covering Tubi's content recommendation system architecture, philosophical insights into the nature of computation, and practical experiences with reactive streams in large‑scale JVM environments, followed by a round‑table discussion and audience feedback.
RSocket is a binary, back‑pressure‑aware protocol that supports four interaction models—fire‑and‑forget, request‑response, request‑stream, and request‑channel—using multiplexed frames with odd/even stream IDs for true bidirectional communication, and provides a reactive, resumable API suitable for microservices, IoT, and broker‑based architectures.
This article walks through the evolution of Java asynchronous programming, starting with a simple synchronous HTTP call, examining blocking I/O, exploring JDK NIO and Future, demonstrating callback patterns, addressing callback hell, and showing how CompletableFuture, Vert.x Future, Reactive Streams, and Spring WebFlux provide scalable, non‑blocking solutions.
This tutorial introduces RSocket—a reactive, binary, multiplexed protocol—and demonstrates how to install the RSC client, create a Spring Boot RSocket server, and implement all four interaction models (request‑response, fire‑forget, stream, and channel) with complete code examples.
This article explains what reactive programming is, outlines the Reactive Manifesto's four core principles, describes the Reactive Streams standard and its key interfaces, showcases Java code examples with Reactor, and provides practical guidance for adopting reactive architectures in backend systems.
This article explains why Tubi rewrote its legacy PHP ad platform, how it adopted Scala, Akka, and Reactive Streams to model the ad request lifecycle as a reactive stream, and details the first three processing steps—parsing, enrichment, and precise filtering—along with sample Scala filter code.
RSocket is a binary, reactive‑streams‑based point‑to‑point protocol offering asynchronous, back‑pressure‑aware, multiplexed communication with four interaction models, making it a high‑performance alternative to HTTP for distributed systems, though it remains in candidate status and has a steep learning curve.
This article explains the Reactive Streams standard, its back‑pressure concept—including blocking and non‑blocking approaches—and details the core API types (Publisher, Subscriber, Subscription) and their interaction flow for asynchronous data processing.
