reactor-extra

library3.6.0javamavenunverified

Provides additional utilities, helpers, and custom operators for the Reactor reactive programming library.

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

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · REACTOR-EXTRA

reactor-extra

utilityjavav3.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.

TopicProcessor

✓ reactor.extra.processor.TopicProcessor

Minimal example showing how to create and use a TopicProcessor from Reactor Extra.

import reactor.extra.processor.TopicProcessor; public class Example { public static void main(String[] args) { TopicProcessor<String> processor = TopicProcessor.create(); processor.subscribe(data -> System.out.println("Received: " + data)); processor.onNext("Hello, Reactor Extra!"); } }

Debug

Known issues

No known issues recorded.

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-extra/ ↗