Package zmq.io.coder

Class EncoderBase

java.lang.Object
zmq.io.coder.EncoderBase
All Implemented Interfaces:
IEncoder
Direct Known Subclasses:
Encoder

public abstract class EncoderBase extends Object implements IEncoder
  • Field Details

    • writeBuf

      private ByteBuffer writeBuf
    • next

      private Runnable next
    • newMsgFlag

      private boolean newMsgFlag
    • toWrite

      private int toWrite
    • buffer

      private final ByteBuffer buffer
    • bufferSize

      private final int bufferSize
    • error

      private boolean error
    • inProgress

      protected Msg inProgress
    • errno

      private final Errno errno
  • Constructor Details

    • EncoderBase

      protected EncoderBase(Errno errno, int bufferSize)
  • Method Details

    • loadMsg

      public final void loadMsg(Msg msg)
      Specified by:
      loadMsg in interface IEncoder
    • encode

      public final int encode(ValueReference<ByteBuffer> data, int size)
      Specified by:
      encode in interface IEncoder
    • encoded

      public void encoded()
      Specified by:
      encoded in interface IEncoder
    • encodingError

      protected void encodingError()
    • isError

      public final boolean isError()
    • next

      protected void next()
    • nextStep

      protected void nextStep(Msg msg, Runnable state, boolean beginning)
    • nextStep

      private void nextStep(byte[] buf, int toWrite, Runnable next, boolean newMsgFlag)
    • initStep

      protected void initStep(Runnable next, boolean newMsgFlag)
    • nextStep

      private void nextStep(ByteBuffer buf, Runnable next, boolean newMsgFlag)
    • nextStep

      protected void nextStep(ByteBuffer buf, int toWrite, Runnable next, boolean newMsgFlag)
    • errno

      public int errno()
    • errno

      public void errno(int err)
    • destroy

      public void destroy()
      Specified by:
      destroy in interface IEncoder