Class ChannelTaskSerializer

  • public class ChannelTaskSerializer
    extends java.lang.Object
    The purpose of this class is to execute tasks in series without overlap, even if the executeTask(Consumer, ChannelFutureListener) method is called before the completion if the previous tasks. The next task is not started until after the provided ChannelFutureListener returns. If the task fails to complete by completing the ChannelPromise, the serializer becomes blocked. It may be possible to add a PhantomReference to detect when the ChannelPromise completion has been lost and to enact some kind of recovery.
    • Constructor Summary

      Constructor Description
      ChannelTaskSerializer​( ctx)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void executeTask​(java.util.function.Consumer<> task, listener)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ChannelTaskSerializer

        public ChannelTaskSerializer​(@Nonnull
    • Method Detail

      • executeTask

        public void executeTask​(@Nonnull
                                java.util.function.Consumer<> task,