模块 org.redkale

程序包 org.redkale.util

类 Flows

java.lang.Object

org.redkale.util.Flows

public abstract class Flows
extends Object

Flow简单的操作

详情见: https://redkale.org

从以下版本开始:

2.5.0

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	Flows.SubscriberFuture<T>	简单的CompletableFuture与Flow.Subscriber的结合类。
static class	Flows.SubscriberListFuture<T>	简单的CompletableFuture与Flow.Subscriber的结合类。

方法概要

修饰符和类型	方法	说明
static <T> CompletableFuture<List<T>>	createFluxFuture(Flow.Publisher<T> publisher)
static <T> CompletableFuture<T>	createMonoFuture(Flow.Publisher<T> publisher)
static boolean	maybePublisherClass(Class value)
static Type	maybePublisherSubType(Type value)
static Object	maybePublisherToFuture(Object value)

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

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

方法详细资料

maybePublisherClass

public static boolean maybePublisherClass(Class value)

maybePublisherSubType

public static Type maybePublisherSubType(Type value)

maybePublisherToFuture

public static Object maybePublisherToFuture(Object value)

createFluxFuture

public static final <T> CompletableFuture<List<T>> createFluxFuture(Flow.Publisher<T> publisher)

createMonoFuture

public static final <T> CompletableFuture<T> createMonoFuture(Flow.Publisher<T> publisher)