reactor.adapter

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

作者:

Stephane Maldini, Sebastien Deleuze

方法概要

限定符和类型	方法和说明
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 java Flow.Publisher from a Flux

从类继承的方法 java.lang.Object

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

方法详细资料

publisherToFlowPublisher

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

Return a java Flow.Publisher from a Flux

类型参数:

T - the type of the publisher

参数:

publisher - the source Publisher to convert

返回:

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

类型参数:

T - the type of the publisher

参数:

publisher - the source Publisher to convert

返回:

a Flux from a java Flow.Publisher