Class AbstractStreamEncoder<E extends Enum<E>>

java.lang.Object
org.apache.maven.surefire.api.stream.AbstractStreamEncoder<E>
Type Parameters:
E - type of the message
Direct Known Subclasses:
CommandEncoder, EventEncoder

public abstract class AbstractStreamEncoder<E extends Enum<E>> extends Object
The base class of stream encoder. The type of message is expressed by opcode where the opcode object is described by the generic type AbstractStreamEncoder.
  • Field Details

    • BOOLEAN_NON_NULL_OBJECT

      private static final byte BOOLEAN_NON_NULL_OBJECT
      See Also:
    • BOOLEAN_NULL_OBJECT

      private static final byte BOOLEAN_NULL_OBJECT
      See Also:
    • INT_BINARY

      private static final byte[] INT_BINARY
    • out

      private final WritableByteChannel out
  • Constructor Details

  • Method Details

    • getEncodedMagicNumber

      @Nonnull protected abstract byte[] getEncodedMagicNumber()
    • enumToByteArray

      @Nonnull protected abstract byte[] enumToByteArray(E e)
    • getEncodedCharsetName

      @Nonnull protected abstract byte[] getEncodedCharsetName()
    • getCharset

      @Nonnull protected abstract Charset getCharset()
    • newCharsetEncoder

      @Nonnull protected abstract CharsetEncoder newCharsetEncoder()
    • write

      protected void write(ByteBuffer frame, boolean sendImmediately) throws IOException
      Throws:
      IOException
    • encodeHeader

      public void encodeHeader(ByteBuffer result, E operation, RunMode runMode, Long testRunId)
    • encodeHeader

      public void encodeHeader(ByteBuffer result, E operation)
    • encodeCharset

      public void encodeCharset(ByteBuffer result)
    • encodeString

      public void encodeString(CharsetEncoder encoder, ByteBuffer result, String string)
    • encodeInteger

      public void encodeInteger(ByteBuffer result, Integer i)
    • encode

      public void encode(CharsetEncoder encoder, ByteBuffer result, E operation, RunMode runMode, Long testRunId, String... messages)
    • encode

      public void encode(CharsetEncoder encoder, ByteBuffer result, E operation, String... messages)
    • encodeStringData

      private void encodeStringData(ByteBuffer result, CharsetEncoder encoder, String... messages)
    • estimateBufferLength

      public int estimateBufferLength(int opcodeLength, RunMode runMode, CharsetEncoder encoder, int integersCounter, int longsCounter, String... strings)
    • nonNull

      private static String nonNull(String msg)