software.amazon.awssdk.http.nio.netty.internal.utils

Class NettyUtils

java.lang.Object

software.amazon.awssdk.http.nio.netty.internal.utils.NettyUtils

public final class NettyUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.concurrent.SucceededFuture<?>	SUCCEEDED_FUTURE Completed succeed future.

Method Summary

Modifier and Type	Method and Description
static <SuccessT,PromiseT> BiConsumer<SuccessT,? super Throwable>	asyncPromiseNotifyingBiConsumer(BiConsumer<SuccessT,io.netty.util.concurrent.Promise<PromiseT>> successConsumer, io.netty.util.concurrent.Promise<PromiseT> promise) Creates a BiConsumer that notifies the promise of any failures either via the throwable passed into the BiConsumer or as a result of running the successConsumer.
static void	doInEventLoop(io.netty.util.concurrent.EventExecutor eventExecutor, Runnable runnable) Runs a task in the given EventExecutor.
static void	doInEventLoop(io.netty.util.concurrent.EventExecutor eventExecutor, Runnable runnable, io.netty.util.concurrent.Promise<?> promise) Runs a task in the given EventExecutor.
static <SuccessT,PromiseT> BiConsumer<SuccessT,? super Throwable>	promiseNotifyingBiConsumer(Function<SuccessT,PromiseT> successFunction, io.netty.util.concurrent.Promise<PromiseT> promise) Creates a BiConsumer that notifies the promise of any failures either via the Throwable passed into the BiConsumer of as a result of running the successFunction.
static <T> io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<T>>	promiseNotifyingListener(io.netty.util.concurrent.Promise<T> channelPromise) Create a GenericFutureListener that will notify the provided Promise on success and failure.

Methods inherited from class java.lang.Object

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

Field Detail

SUCCEEDED_FUTURE

public static final io.netty.util.concurrent.SucceededFuture<?> SUCCEEDED_FUTURE

Completed succeed future.

Method Detail

promiseNotifyingBiConsumer

public static <SuccessT,PromiseT> BiConsumer<SuccessT,? super Throwable> promiseNotifyingBiConsumer(Function<SuccessT,PromiseT> successFunction,
                                                                                                    io.netty.util.concurrent.Promise<PromiseT> promise)

Creates a BiConsumer that notifies the promise of any failures either via the Throwable passed into the BiConsumer of as a result of running the successFunction.

Type Parameters:

SuccessT - Success type.

PromiseT - Type being fulfilled by the promise.

Parameters:

successFunction - Function called to process the successful result and map it into the result to notify the promise with.

promise - Promise to notify of success or failure.

Returns:

BiConsumer that can be used in a CompletableFuture.whenComplete(BiConsumer) method.

asyncPromiseNotifyingBiConsumer

public static <SuccessT,PromiseT> BiConsumer<SuccessT,? super Throwable> asyncPromiseNotifyingBiConsumer(BiConsumer<SuccessT,io.netty.util.concurrent.Promise<PromiseT>> successConsumer,
                                                                                                         io.netty.util.concurrent.Promise<PromiseT> promise)

Creates a BiConsumer that notifies the promise of any failures either via the throwable passed into the BiConsumer or as a result of running the successConsumer. This assumes that the successConsumer will notify the promise when it completes successfully.

Type Parameters:

SuccessT - Success type.

PromiseT - Type being fulfilled by the Promise.

Parameters:

successConsumer - BiConsumer to call if the result is successful. Promise is also passed and must be notified on success.

promise - Promise to notify.

Returns:

BiConsumer that can be used in a CompletableFuture.whenComplete(BiConsumer) method.

promiseNotifyingListener

public static <T> io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<T>> promiseNotifyingListener(io.netty.util.concurrent.Promise<T> channelPromise)

Create a GenericFutureListener that will notify the provided Promise on success and failure.

Parameters:

channelPromise - Promise to notify.

Returns:

GenericFutureListener

doInEventLoop

public static void doInEventLoop(io.netty.util.concurrent.EventExecutor eventExecutor,
                                 Runnable runnable)

Runs a task in the given EventExecutor. Runs immediately if the current thread is in the eventExecutor.

Parameters:

eventExecutor - Executor to run task in.

runnable - Task to run.

doInEventLoop

public static void doInEventLoop(io.netty.util.concurrent.EventExecutor eventExecutor,
                                 Runnable runnable,
                                 io.netty.util.concurrent.Promise<?> promise)

Runs a task in the given EventExecutor. Runs immediately if the current thread is in the eventExecutor. Notifies the given Promise if a failure occurs.

Parameters:

eventExecutor - Executor to run task in.

runnable - Task to run.

promise - Promise to notify if failure occurs.