reactor.adapter

Class JdkFlowAdapter

java.lang.Object

reactor.adapter.JdkFlowAdapter

public abstract class JdkFlowAdapter
extends java.lang.Object

Convert a Java 9+ Flow.Publisher to/from a Reactive Streams Publisher.

Method Summary

Modifier and Type	Method and Description
static <T> Flux<T>	flowPublisherToFlux(java.util.concurrent.Flow.Publisher<T> publisher) Return a Flux from a java Flow.Publisher
static <T> java.util.concurrent.Flow.Publisher<T>	publisherToFlowPublisher(org.reactivestreams.Publisher<T> publisher) Return a Flux from a java Flow.Publisher

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

publisherToFlowPublisher

public static <T> java.util.concurrent.Flow.Publisher<T> publisherToFlowPublisher(org.reactivestreams.Publisher<T> publisher)

Return a Flux from a java Flow.Publisher

Type Parameters:

T - the type of the publisher

Parameters:

publisher - the source Publisher to convert

Returns:

a java Flow.Publisher from the given Publisher

flowPublisherToFlux

public static <T> Flux<T> flowPublisherToFlux(java.util.concurrent.Flow.Publisher<T> publisher)

Return a Flux from a java Flow.Publisher

Type Parameters:

T - the type of the publisher

Parameters:

publisher - the source Publisher to convert

Returns:

a Flux from a java Flow.Publisher