org.apache.maven.surefire.stream

Class EventDecoder

java.lang.Object

org.apache.maven.surefire.api.stream.AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

org.apache.maven.surefire.stream.EventDecoder

All Implemented Interfaces:

AutoCloseable

public class EventDecoder
extends AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Nested Class Summary

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

AbstractStreamDecoder.BufferedStream, AbstractStreamDecoder.MalformedFrameException, AbstractStreamDecoder.Memento, AbstractStreamDecoder.Segment, AbstractStreamDecoder.StreamReadStatus

Field Summary

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

BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
EventDecoder(ReadableByteChannel channel, ForkNodeArguments arguments)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	debugStream(byte[] array, int position, int remaining)
Event	decode(AbstractStreamDecoder.Memento memento)
protected byte[]	getEncodedMagicNumber()
protected SegmentType[]	nextSegmentType(ForkedProcessEventType eventType)
protected Event	toMessage(ForkedProcessEventType eventType, 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
                    ReadableByteChannel channel,
                    @Nonnull
                    ForkNodeArguments arguments)

Method Detail

decode

public Event decode(@Nonnull
                    AbstractStreamDecoder.Memento memento)
             throws IOException

Specified by:

decode in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Throws:

IOException

getEncodedMagicNumber

@Nonnull
protected final byte[] getEncodedMagicNumber()

Specified by:

getEncodedMagicNumber in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

nextSegmentType

@Nonnull
protected final SegmentType[] nextSegmentType(@Nonnull
                                                        ForkedProcessEventType eventType)

Specified by:

nextSegmentType in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

toMessage

@Nonnull
protected final Event toMessage(@Nonnull
                                          ForkedProcessEventType eventType,
                                          @Nonnull
                                          AbstractStreamDecoder.Memento memento)
                                   throws AbstractStreamDecoder.MalformedFrameException

Specified by:

toMessage in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Throws:

AbstractStreamDecoder.MalformedFrameException

debugStream

protected void debugStream(byte[] array,
                           int position,
                           int remaining)

Overrides:

debugStream in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

close

public void close()
           throws IOException

Throws:

IOException