io.servicetalk.transport.netty.internal

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

A Completable that wraps a netty Future.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource

CompletableSource.Processor, CompletableSource.Subscriber

Constructor Summary

Constructors

Constructor and Description
NettyFutureCompletable(java.util.function.Supplier<io.netty.util.concurrent.Future<?>> futureSupplier) New instance.

Method Summary

Modifier and Type	Method and Description
protected void	handleSubscribe(CompletableSource.Subscriber subscriber) Handles a subscriber to this Completable.

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, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyFutureCompletable

public NettyFutureCompletable(java.util.function.Supplier<io.netty.util.concurrent.Future<?>> futureSupplier)

New instance.

Parameters:

futureSupplier - A Supplier that is invoked every time this Completable is subscribed.

Method Detail

handleSubscribe

protected void handleSubscribe(CompletableSource.Subscriber subscriber)

Description copied from class: Completable

Handles a subscriber to this Completable.

This method is invoked internally by Completable for every call to the Completable.subscribeInternal(CompletableSource.Subscriber) method.

Specified by:

handleSubscribe in class Completable

Parameters:

subscriber - the subscriber.