io.jstuff.pipeline.buffer

Class ByteArrayPipeline<R>

java.lang.Object

io.jstuff.pipeline.BaseAbstractAcceptor<R>

io.jstuff.pipeline.AbstractAcceptor<A,R>

io.jstuff.pipeline.AbstractObjectIntPipeline<byte[],R>

io.jstuff.pipeline.buffer.ByteArrayPipeline<R>

Type Parameters:

R - the result type

All Implemented Interfaces:

Acceptor<byte[],R>, BaseAcceptor<R>, BasePipeline<R>, ObjectIntPipeline<byte[],R>, AutoCloseable, Consumer<byte[]>

public class ByteArrayPipeline<R>
extends AbstractObjectIntPipeline<byte[],R>

A pipeline that takes byte arrays and emits each byte as an int.

Author:

Peter Wall

Constructor Summary

Constructors

Constructor and Description
ByteArrayPipeline(IntAcceptor<? extends R> downstream) Construct a ByteArrayPipeline with the given downstream IntAcceptor.

Method Summary

Modifier and Type	Method and Description
void	accept(byte[] value, int offset, int length) Accept a byte array with the specified offset and length.
void	acceptObject(byte[] value) Accept a byte array, after closed check and test for end of data.
void	acceptObject(byte[] value, int offset, int length) Accept a byte array with the specified offset and length, after closed check and test for end of data.

Methods inherited from class io.jstuff.pipeline.AbstractObjectIntPipeline

close, emit, flush, getDownstream

Methods inherited from class io.jstuff.pipeline.AbstractAcceptor

accept, accept

Methods inherited from class io.jstuff.pipeline.BaseAbstractAcceptor

isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.jstuff.pipeline.Acceptor

accept, accept, accept, accept, accept

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface io.jstuff.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface io.jstuff.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

ByteArrayPipeline

public ByteArrayPipeline(IntAcceptor<? extends R> downstream)

Construct a ByteArrayPipeline with the given downstream IntAcceptor.

Parameters:

downstream - the IntAcceptor

Method Detail

acceptObject

public void acceptObject(byte[] value)

Accept a byte array, after closed check and test for end of data. Emit each byte to the downstream IntAcceptor.

Specified by:

acceptObject in class AbstractAcceptor<byte[],R>

Parameters:

value - the input value

accept

public void accept(byte[] value,
                   int offset,
                   int length)

Accept a byte array with the specified offset and length. Check for pipeline already closed, and handle end of data. Emit each byte to the downstream IntAcceptor.

Parameters:

value - the input value

offset - the offset from the start of the buffer

length - the length (number of bytes) to process

Throws:

IllegalStateException - if the ByteArrayPipeline has already been closed

acceptObject

public void acceptObject(byte[] value,
                         int offset,
                         int length)

Accept a byte array with the specified offset and length, after closed check and test for end of data. Emit each byte to the downstream IntAcceptor.

Parameters:

value - the input value

offset - the offset from the start of the buffer

length - the length (number of bytes) to process