reactor-adapter

library3.6.0javamavenunverified

Adapters for integrating Project Reactor with RxJava2, RxJava3, and Akka Streams.

<dependency>
  <groupId>io.projectreactor.addons</groupId>
  <artifactId>reactor-adapter</artifactId>
  <version>3.6.0</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · REACTOR-ADAPTER

reactor-adapter

networkingjavav3.6.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

RxJava2Adapter

✓ reactor.adapter.rxjava.RxJava2Adapter

Converts a Reactor Flux to an RxJava Flowable and subscribes.

import reactor.adapter.rxjava.RxJava2Adapter; import reactor.core.publisher.Flux; import io.reactivex.Flowable; public class Example { public static void main(String[] args) { Flux<Integer> flux = Flux.just(1, 2, 3); Flowable<Integer> flowable = RxJava2Adapter.fluxToFlowable(flux); flowable.subscribe(System.out::println); } }

Debug

Known issues

breakingReactor Adapter 3.6.0 requires Reactor Core 3.6.x and RxJava 2.x or 3.x.

fix

Ensure compatible versions of Reactor and RxJava are used.

affects: >=3.6.0

Upgrade

Version history

3.6.0latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

8 hits · last 30 days

node

Resources

githubhttps://github.com/reactor/reactor-addons ↗

homepagehttps://github.com/reactor/reactor-addons ↗

docshttps://appdoc.app/artifact/io.projectreactor.addons/reactor-adapter/ ↗