Package zmq.io.coder

Class EncoderBase

  • All Implemented Interfaces:
    IEncoder
    Direct Known Subclasses:
    Encoder

    public abstract class EncoderBase
    extends java.lang.Object
    implements IEncoder
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected EncoderBase​(Errno errno, int bufferSize)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void destroy()  
      int encode​(ValueReference<java.nio.ByteBuffer> data, int size)  
      void encoded()  
      protected void encodingError()  
      int errno()  
      void errno​(int err)  
      protected void initStep​(java.lang.Runnable next, boolean newMsgFlag)  
      boolean isError()  
      void loadMsg​(Msg msg)  
      protected void next()  
      private void nextStep​(byte[] buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)  
      protected void nextStep​(java.nio.ByteBuffer buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)  
      private void nextStep​(java.nio.ByteBuffer buf, java.lang.Runnable next, boolean newMsgFlag)  
      protected void nextStep​(Msg msg, java.lang.Runnable state, boolean beginning)  
      • Methods inherited from class java.lang.Object

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

      • writeBuf

        private java.nio.ByteBuffer writeBuf
      • next

        private java.lang.Runnable next
      • newMsgFlag

        private boolean newMsgFlag
      • toWrite

        private int toWrite
      • buffer

        private final java.nio.ByteBuffer buffer
      • bufferSize

        private final int bufferSize
      • error

        private boolean error
      • inProgress

        protected Msg inProgress
      • errno

        private final Errno errno
    • Constructor Detail

      • EncoderBase

        protected EncoderBase​(Errno errno,
                              int bufferSize)
    • Method Detail

      • loadMsg

        public final void loadMsg​(Msg msg)
        Specified by:
        loadMsg 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,
                                java.lang.Runnable state,
                                boolean beginning)
      • nextStep

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

        protected void initStep​(java.lang.Runnable next,
                                boolean newMsgFlag)
      • nextStep

        private void nextStep​(java.nio.ByteBuffer buf,
                              java.lang.Runnable next,
                              boolean newMsgFlag)
      • nextStep

        protected void nextStep​(java.nio.ByteBuffer buf,
                                int toWrite,
                                java.lang.Runnable next,
                                boolean newMsgFlag)
      • errno

        public int errno()
      • errno

        public void errno​(int err)
      • destroy

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