Class NettyFutureCompletable
- java.lang.Object
-
- io.servicetalk.concurrent.api.Completable
-
- io.servicetalk.concurrent.api.internal.SubscribableCompletable
-
- io.servicetalk.transport.netty.internal.NettyFutureCompletable
-
- All Implemented Interfaces:
CompletableSource
public final class NettyFutureCompletable extends SubscribableCompletable
ACompletable
that wraps a nettyFuture
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource
CompletableSource.Processor, CompletableSource.Subscriber
-
-
Constructor Summary
Constructors Constructor Description NettyFutureCompletable(java.util.function.Supplier<io.netty.util.concurrent.Future<?>> futureSupplier)
New instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
handleSubscribe(CompletableSource.Subscriber subscriber)
Handles a subscriber to thisCompletable
.-
Methods inherited from class io.servicetalk.concurrent.api.internal.SubscribableCompletable
subscribe
-
Methods inherited from class io.servicetalk.concurrent.api.Completable
afterCancel, afterFinally, afterFinally, afterOnComplete, afterOnError, afterOnSubscribe, afterSubscriber, amb, amb, ambWith, anyOf, anyOf, beforeCancel, beforeFinally, beforeFinally, beforeOnComplete, beforeOnError, beforeOnSubscribe, beforeSubscriber, completed, concat, concat, concat, defer, failed, fromFuture, fromRunnable, fromStage, idleTimeout, idleTimeout, idleTimeout, idleTimeout, liftAsync, liftSync, merge, merge, merge, merge, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, never, onErrorResume, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, repeat, repeatWhen, retry, retryWhen, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, toCompletionStage, toFuture, toPublisher, toSingle, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnSubscribe, whenSubscriber
-
-
-
-
Constructor Detail
-
NettyFutureCompletable
public NettyFutureCompletable(java.util.function.Supplier<io.netty.util.concurrent.Future<?>> futureSupplier)
New instance.- Parameters:
futureSupplier
- ASupplier
that is invoked every time thisCompletable
is subscribed.
-
-
Method Detail
-
handleSubscribe
protected void handleSubscribe(CompletableSource.Subscriber subscriber)
Description copied from class:Completable
Handles a subscriber to thisCompletable
.This method is invoked internally by
Completable
for every call to theCompletable.subscribeInternal(CompletableSource.Subscriber)
method.- Specified by:
handleSubscribe
in classCompletable
- Parameters:
subscriber
- the subscriber.
-
-