org.forgerock.http.io

Class PipeBufferedStream

java.lang.Object

org.forgerock.http.io.PipeBufferedStream

public final class PipeBufferedStream
extends Object

Represents a pipe for transferring bytes from an OutputStream to a BranchingInputStream. This class is not thread-safe : the buffer has to be fully filled before reading from it : if the consumers reads faster than the producer writes into it, then the consumer will get to the end of the buffer and that will be interpreted an end-of-stream.

Constructor Summary

Constructors

Constructor and Description
PipeBufferedStream() Constructs a new PipeBufferedStream with a default Factory.
PipeBufferedStream(Factory<Buffer> bufferFactory) Constructs a new PipeBufferedStream with the given Factory.

Method Summary

Modifier and Type	Method and Description
OutputStream	getIn() Returns the output stream which writes to the pipe.
BranchingInputStream	getOut() Returns the input stream which reads from the pipe.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeBufferedStream

public PipeBufferedStream()

Constructs a new PipeBufferedStream with a default Factory.

PipeBufferedStream

public PipeBufferedStream(Factory<Buffer> bufferFactory)

Constructs a new PipeBufferedStream with the given Factory.

Parameters:

bufferFactory - The buffer factory to use to create the BranchingInputStream

Method Detail

getIn

public OutputStream getIn()

Returns the output stream which writes to the pipe.

Returns:

The output stream.

getOut

public BranchingInputStream getOut()

Returns the input stream which reads from the pipe.

Returns:

The input stream.