Package com.linkedin.alpini.netty4.misc

Class Futures

  • public final class Futures
extends java.lang.Object
    Created by acurtis on 2/1/17.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static io.netty.util.concurrent.Future<java.lang.Void> allOf​(io.netty.util.concurrent.EventExecutor eventExecutor, io.netty.util.concurrent.Future<?>... futures)  
      static io.netty.util.concurrent.Future<java.lang.Void> allOf​(io.netty.util.concurrent.Future<?>... futures)  
      static io.netty.util.concurrent.Future<?> anyOf​(io.netty.util.concurrent.Future<?>... futures)  
      static <T> java.util.concurrent.CompletableFuture<T> asCompletableFuture​(io.netty.util.concurrent.Future<T> future)  
      static <T> io.netty.util.concurrent.Future<T> asNettyFuture​(io.netty.util.concurrent.EventExecutor eventExecutor, java.util.concurrent.CompletableFuture<T> completableFuture)  
      static <T> io.netty.util.concurrent.Future<T> asNettyFuture​(java.util.concurrent.CompletableFuture<T> completableFuture)  
      static <V> java.util.function.BiConsumer<V,​java.lang.Throwable> complete​(io.netty.util.concurrent.Promise<V> promise)  
      static <V> java.util.function.BiConsumer<V,​java.lang.Throwable> complete​(io.netty.util.concurrent.Promise<V> promise, java.util.function.Consumer<V> dispose)  
      static <V> java.util.function.BiConsumer<io.netty.util.concurrent.Future<V>,​java.lang.Throwable> completeFuture​(io.netty.util.concurrent.Promise<V> promise)  
      static <V> io.netty.util.concurrent.FutureListener<V> listener​(io.netty.util.concurrent.Promise<V> promise)  
      static <V> io.netty.util.concurrent.FutureListener<V> listener​(io.netty.util.concurrent.Promise<V> promise, java.util.function.Consumer<V> dispose)  
      static <V> io.netty.util.concurrent.FutureListener<V> listener​(java.util.concurrent.CompletableFuture<V> completableFuture)  
      static <V> io.netty.util.concurrent.FutureListener<V> listener​(java.util.concurrent.CompletableFuture<V> completableFuture, java.util.function.Consumer<V> dispose)  
      static <T,​V>
      io.netty.util.concurrent.FutureListener<T>      		 voidListener​(io.netty.util.concurrent.Promise<V> promise)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • asCompletableFuture

        public static <T> java.util.concurrent.CompletableFuture<T> asCompletableFuture​(io.netty.util.concurrent.Future<T> future)

      • asNettyFuture

        public static <T> io.netty.util.concurrent.Future<T> asNettyFuture​(@Nonnull
                                                                   java.util.concurrent.CompletableFuture<T> completableFuture)

      • asNettyFuture

        public static <T> io.netty.util.concurrent.Future<T> asNettyFuture​(@Nonnull
                                                                   io.netty.util.concurrent.EventExecutor eventExecutor,
                                                                   @Nonnull
                                                                   java.util.concurrent.CompletableFuture<T> completableFuture)

      • allOf

        public static io.netty.util.concurrent.Future<java.lang.Void> allOf​(io.netty.util.concurrent.Future<?>... futures)

      • allOf

        public static io.netty.util.concurrent.Future<java.lang.Void> allOf​(@Nonnull
                                                                    io.netty.util.concurrent.EventExecutor eventExecutor,
                                                                    io.netty.util.concurrent.Future<?>... futures)

      • anyOf

        public static io.netty.util.concurrent.Future<?> anyOf​(io.netty.util.concurrent.Future<?>... futures)

      • complete

        public static <V> java.util.function.BiConsumer<V,​java.lang.Throwable> complete​(@Nonnull
                                                                                      io.netty.util.concurrent.Promise<V> promise)

      • complete

        public static <V> java.util.function.BiConsumer<V,​java.lang.Throwable> complete​(@Nonnull
                                                                                      io.netty.util.concurrent.Promise<V> promise,
                                                                                      @Nonnull
                                                                                      java.util.function.Consumer<V> dispose)

      • completeFuture

        public static <V> java.util.function.BiConsumer<io.netty.util.concurrent.Future<V>,​java.lang.Throwable> completeFuture​(@Nonnull
                                                                                                                             io.netty.util.concurrent.Promise<V> promise)

      • voidListener

        public static <T,​V> io.netty.util.concurrent.FutureListener<T> voidListener​(@Nonnull
                                                                                  io.netty.util.concurrent.Promise<V> promise)

      • listener

        public static <V> io.netty.util.concurrent.FutureListener<V> listener​(@Nonnull
                                                                      io.netty.util.concurrent.Promise<V> promise)

      • listener

        public static <V> io.netty.util.concurrent.FutureListener<V> listener​(@Nonnull
                                                                      io.netty.util.concurrent.Promise<V> promise,
                                                                      @Nonnull
                                                                      java.util.function.Consumer<V> dispose)

      • listener

        public static <V> io.netty.util.concurrent.FutureListener<V> listener​(@Nonnull
                                                                      java.util.concurrent.CompletableFuture<V> completableFuture)

      • listener

        public static <V> io.netty.util.concurrent.FutureListener<V> listener​(@Nonnull
                                                                      java.util.concurrent.CompletableFuture<V> completableFuture,
                                                                      @Nonnull
                                                                      java.util.function.Consumer<V> dispose)