Package 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	Description
EventDecoder(ReadableByteChannel channel, ForkNodeArguments arguments)

Method Summary

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

EventDecoder

public EventDecoder(@Nonnull
 ReadableByteChannel channel,
 @Nonnull
 ForkNodeArguments arguments)

Method Details

decode

public Event decode(@Nonnull
 AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>.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<Event,ForkedProcessEventType,SegmentType>.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