Package org.apache.maven.surefire.stream

Class EventDecoder

  • All Implemented Interfaces:
    java.lang.AutoCloseable
    public class EventDecoder
extends org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

        org.apache.maven.surefire.api.stream.AbstractStreamDecoder.BufferedStream, org.apache.maven.surefire.api.stream.AbstractStreamDecoder.MalformedFrameException, org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Memento, org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Segment, org.apache.maven.surefire.api.stream.AbstractStreamDecoder.StreamReadStatus

    • Field Summary

      • Fields inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

        BUFFER_SIZE

    • Constructor Summary

      Constructors 
      Constructor Description
      EventDecoder​(java.nio.channels.ReadableByteChannel channel, org.apache.maven.surefire.api.fork.ForkNodeArguments arguments)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      protected void debugStream​(byte[] array, int position, int remaining)  
      org.apache.maven.surefire.api.event.Event decode​(org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Memento memento)  
      protected byte[] getEncodedMagicNumber()  
      protected org.apache.maven.surefire.api.stream.SegmentType[] nextSegmentType​(org.apache.maven.surefire.api.booter.ForkedProcessEventType eventType)  
      protected org.apache.maven.surefire.api.event.Event toMessage​(org.apache.maven.surefire.api.booter.ForkedProcessEventType eventType, org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Memento memento)  

      • Methods inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

        checkArguments, checkDelimiter, checkHeader, getArguments, printRemainingStream, read, readByte, readCharset, readInt, readInteger, readLong, readLongPrivate, readMessageType, readSegment, readString

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • EventDecoder

        public EventDecoder​(@Nonnull
                    java.nio.channels.ReadableByteChannel channel,
                    @Nonnull
                    org.apache.maven.surefire.api.fork.ForkNodeArguments arguments)

    • Method Detail

      • decode

        public org.apache.maven.surefire.api.event.Event decode​(@Nonnull
                                                        org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Memento memento)
                                                 throws java.io.IOException
        Specified by:
        decode in class org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>
        Throws:
        java.io.IOException

      • getEncodedMagicNumber

        @Nonnull
protected final byte[] getEncodedMagicNumber()
        Specified by:
        getEncodedMagicNumber in class org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>

      • nextSegmentType

        @Nonnull
protected final org.apache.maven.surefire.api.stream.SegmentType[] nextSegmentType​(@Nonnull
                                                                                   org.apache.maven.surefire.api.booter.ForkedProcessEventType eventType)
        Specified by:
        nextSegmentType in class org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>

      • toMessage

        @Nonnull
protected final org.apache.maven.surefire.api.event.Event toMessage​(@Nonnull
                                                                    org.apache.maven.surefire.api.booter.ForkedProcessEventType eventType,
                                                                    @Nonnull
                                                                    org.apache.maven.surefire.api.stream.AbstractStreamDecoder.Memento memento)
                                                             throws org.apache.maven.surefire.api.stream.AbstractStreamDecoder.MalformedFrameException
        Specified by:
        toMessage in class org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>
        Throws:
        org.apache.maven.surefire.api.stream.AbstractStreamDecoder.MalformedFrameException

      • debugStream

        protected void debugStream​(byte[] array,
                           int position,
                           int remaining)
        Overrides:
        debugStream in class org.apache.maven.surefire.api.stream.AbstractStreamDecoder<org.apache.maven.surefire.api.event.Event,​org.apache.maven.surefire.api.booter.ForkedProcessEventType,​org.apache.maven.surefire.api.stream.SegmentType>

      • close

        public void close()
           throws java.io.IOException
        Throws:
        java.io.IOException