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