net.pwall.pipeline.buffer

Class ByteBufferPipeline<R>

java.lang.Object

net.pwall.pipeline.BaseAbstractAcceptor<R>

net.pwall.pipeline.AbstractAcceptor<A,R>

net.pwall.pipeline.AbstractObjectIntPipeline<ByteBuffer,R>

net.pwall.pipeline.buffer.ByteBufferPipeline<R>

Type Parameters:

R - the result type

All Implemented Interfaces:

AutoCloseable, Consumer<ByteBuffer>, Acceptor<ByteBuffer,R>, BaseAcceptor<R>, BasePipeline<R>, ObjectIntPipeline<ByteBuffer,R>

public class ByteBufferPipeline<R>
extends AbstractObjectIntPipeline<ByteBuffer,R>

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

Author:

Peter Wall

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	acceptObject(ByteBuffer value) Accept a ByteBuffer, after closed check and test for end of data.

Methods inherited from class net.pwall.pipeline.AbstractObjectIntPipeline

close, emit, flush, getDownstream

Methods inherited from class net.pwall.pipeline.AbstractAcceptor

accept, accept

Methods inherited from class net.pwall.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 net.pwall.pipeline.Acceptor

accept, accept, accept, accept, accept

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface net.pwall.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface net.pwall.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

ByteBufferPipeline

public ByteBufferPipeline(IntAcceptor<? extends R> downstream)

Construct a ByteBufferPipeline with the given downstream IntAcceptor.

Parameters:

downstream - the IntAcceptor

Method Detail

acceptObject

public void acceptObject(ByteBuffer value)

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

Specified by:

acceptObject in class AbstractAcceptor<ByteBuffer,R>

Parameters:

value - the input value