模块 org.redkale

程序包 org.redkale.util

类 Flows.SubscriberFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.redkale.util.Flows.SubscriberFuture<T>

类型参数:

T - T

所有已实现的接口:

CompletionStage<T>, Flow.Subscriber<T>, Future<T>

封闭类:

Flows

public static class Flows.SubscriberFuture<T>
extends CompletableFuture<T>
implements Flow.Subscriber<T>

简单的CompletableFuture与Flow.Subscriber的结合类。

详情见: https://redkale.org

从以下版本开始:

2.5.0

嵌套类概要

从类继承的嵌套类/接口 java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

字段概要

字段

修饰符和类型	字段	说明
protected T	rs

构造器概要

构造器

构造器	说明
SubscriberFuture()

方法概要

修饰符和类型	方法	说明
void	onComplete()
void	onError(Throwable t)
void	onNext(T item)
void	onSubscribe(Flow.Subscription s)

从类继承的方法 java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

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

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

字段详细资料

rs

protected T rs

构造器详细资料

SubscriberFuture

public SubscriberFuture()

方法详细资料

onSubscribe

public void onSubscribe(Flow.Subscription s)

指定者:

onSubscribe 在接口中 Flow.Subscriber<T>

onNext

public void onNext(T item)

指定者:

onNext 在接口中 Flow.Subscriber<T>

onError

public void onError(Throwable t)

指定者:

onError 在接口中 Flow.Subscriber<T>

onComplete

public void onComplete()

指定者:

onComplete 在接口中 Flow.Subscriber<T>