Package 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	Description
NettyFutureCompletable(Supplier<io.netty.util.concurrent.Future<?>> futureSupplier)	New instance.

Method Summary

Modifier and Type	Method	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, cache, cache, cache, cache, completed, concat, concat, concat, concat, defer, failed, fromCallable, fromFuture, fromRunnable, fromStage, liftAsync, liftSync, merge, merge, merge, merge, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, never, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, publishOn, publishOn, repeat, repeatWhen, retry, retryWhen, setContextOnSubscribe, shareContextOnSubscribe, subscribe, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOn, timeout, timeout, timeout, timeout, 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 Details

NettyFutureCompletable

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

New instance.

Parameters:

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

Method Details

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.