Class CommandChannelDecoder

    • Constructor Detail

      • CommandChannelDecoder

        public CommandChannelDecoder​(@Nonnull
                                     java.nio.channels.ReadableByteChannel channel,
                                     @Nonnull
                                     ForkNodeArguments arguments)
    • Method Detail

      • decode

        @Nonnull
        public Command decode()
                       throws java.io.IOException
        Description copied from interface: MasterProcessChannelDecoder
        Reads the bytes from a channel, waiting until the command is read completely or the channel throws EOFException.
        This method is called in a single Thread. The constructor can be called within another thread.
        Specified by:
        decode in interface MasterProcessChannelDecoder
        Returns:
        decoded command
        Throws:
        java.io.IOException - exception in channel
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface MasterProcessChannelDecoder
        Throws:
        java.io.IOException