Netty 4.1.107.Final · io.netty.util.concurrent.PromiseNotifier

Modifier and Type	Field and Description
private static final InternalLogger	logger
private final boolean	logNotifyFailure
private final Promise<? super V>[]	promises

Constructor Summary

Access	Constructor and Description
public	PromiseNotifier(Promise<? super V>... the `Promise`s to notify once this `GenericFutureListener` is notified. promises) Create a new instance.
public	PromiseNotifier(boolean `true` if logging should be done in case notification fails. logNotifyFailure, Promise<? super V>... the `Promise`s to notify once this `GenericFutureListener` is notified. promises) Create a new instance.

Method Summary

Modifier and Type	Method and Description
public static < the type of the value. V, the type of the `Future` F extends Future<V>> F	Returns: the passed in `Future` cascade(final F the `Future` which will be used to listen to for notifying the `Promise`. future, final Promise<? super V> the `Promise` which will be notified promise) Link the `Future` and `Promise` such that if the `Future` completes the `Promise` will be notified.
public static < the type of the value. V, the type of the `Future` F extends Future<V>> F	Returns: the passed in `Future` cascade(boolean `true` if logging should be done in case notification fails. logNotifyFailure, final F the `Future` which will be used to listen to for notifying the `Promise`. future, final Promise<? super V> the `Promise` which will be notified promise) Link the `Future` and `Promise` such that if the `Future` completes the `Promise` will be notified.
public void	operationComplete(F the source `Future` which called this callback future) Implements io.netty.util.concurrent.GenericFutureListener.operationComplete. Invoked when the operation associated with the `Future` has been completed.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

logger	back to summary
private static final InternalLogger logger

logNotifyFailure	back to summary
private final boolean logNotifyFailure

promises	back to summary
private final Promise<? super V>[] promises

Constructor Detail

PromiseNotifier back to summary

PromiseNotifier	back to summary
public PromiseNotifier(Promise<? super V>... promises) Create a new instance. Parameters promises:Promise<? super V>[] the `Promise`s to notify once this `GenericFutureListener` is notified. Annotations @SafeVarargs

public PromiseNotifier(Promise<? super V>... promises)

Create a new instance.

Parameters

promises:Promise<? super V>[]: the Promises to notify once this GenericFutureListener is notified.

Annotations

@SafeVarargs

PromiseNotifier back to summary

PromiseNotifier	back to summary
public PromiseNotifier(boolean logNotifyFailure, Promise<? super V>... promises) Create a new instance. Parameters logNotifyFailure:boolean `true` if logging should be done in case notification fails. promises:Promise<? super V>[] the `Promise`s to notify once this `GenericFutureListener` is notified. Annotations @SafeVarargs

public PromiseNotifier(boolean logNotifyFailure, Promise<? super V>... promises)

Create a new instance.

Parameters

logNotifyFailure:boolean: true if logging should be done in case notification fails.
promises:Promise<? super V>[]: the Promises to notify once this GenericFutureListener is notified.

Annotations

@SafeVarargs

Method Detail

cascade back to summary

cascade	back to summary
public static <V, F extends Future<V>> F cascade(final F future, final Promise<? super V> promise) Link the `Future` and `Promise` such that if the `Future` completes the `Promise` will be notified. Cancellation is propagated both ways such that if the `Future` is cancelled the `Promise` is cancelled and vise-versa. Parameters <V> the type of the value. <F> the type of the `Future` future:F the `Future` which will be used to listen to for notifying the `Promise`. promise:Promise<? super V> the `Promise` which will be notified Returns:F the passed in `Future`

public static <V, F extends Future<V>> F cascade(final F future, final Promise<? super V> promise)

Link the Future and Promise such that if the Future completes the Promise will be notified. Cancellation is propagated both ways such that if the Future is cancelled the Promise is cancelled and vise-versa.

Parameters

<V>: the type of the value.
<F>: the type of the Future
future:F: the Future which will be used to listen to for notifying the Promise.
promise:Promise<? super V>: the Promise which will be notified

Returns:F

the passed in Future

cascade back to summary

cascade	back to summary
public static <V, F extends Future<V>> F cascade(boolean logNotifyFailure, final F future, final Promise<? super V> promise) Link the `Future` and `Promise` such that if the `Future` completes the `Promise` will be notified. Cancellation is propagated both ways such that if the `Future` is cancelled the `Promise` is cancelled and vise-versa. Parameters <V> the type of the value. <F> the type of the `Future` logNotifyFailure:boolean `true` if logging should be done in case notification fails. future:F the `Future` which will be used to listen to for notifying the `Promise`. promise:Promise<? super V> the `Promise` which will be notified Returns:F the passed in `Future` Annotations @SuppressWarnings:unchecked, rawtypes

public static <V, F extends Future<V>> F cascade(boolean logNotifyFailure, final F future, final Promise<? super V> promise)

Parameters

<V>: the type of the value.
<F>: the type of the Future
logNotifyFailure:boolean: true if logging should be done in case notification fails.
future:F: the Future which will be used to listen to for notifying the Promise.
promise:Promise<? super V>: the Promise which will be notified

Returns:F

the passed in Future

Annotations

@SuppressWarnings:unchecked, rawtypes

operationComplete back to summary

operationComplete	back to summary
public void operationComplete(F future) throws Exception Implements io.netty.util.concurrent.GenericFutureListener.operationComplete. Doc from io.netty.util.concurrent.GenericFutureListener.operationComplete. Invoked when the operation associated with the `Future` has been completed. Parameters future:F the source `Future` which called this callback Annotations @Override

public void operationComplete(F future) throws Exception

Implements io.netty.util.concurrent.GenericFutureListener.operationComplete.

Doc from io.netty.util.concurrent.GenericFutureListener.operationComplete.

Invoked when the operation associated with the Future has been completed.

Parameters

future:F: the source Future which called this callback

Annotations

@Override

public Class PromiseNotifier<V, F extends Future<V>>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail