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(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 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, merge, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, never, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, repeat, repeatWhen, retry, retryWhen, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, 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 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.