Package com.levigo.jadice.server.util

Class DynamicPipe

java.lang.Object

java.io.OutputStream

com.levigo.jadice.server.util.DynamicPipe

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class DynamicPipe
extends OutputStream

A pipe implementation similar to the PipedInputStream/ PipedOutputStream combo, but with an unlimited buffer capacity.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DynamicPipe.PipeInputStream	The output end of the pipe.

Field Summary

Fields

Modifier and Type	Field	Description
static int	BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
DynamicPipe()	Create a dynamic pipe.

Method Summary

Modifier and Type	Method	Description
void	close()
InputStream	getReadEnd()
void	propagateException(IOException ioException)	Propagates an IOException to the reading site.
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Field Detail

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

DynamicPipe

public DynamicPipe()

Create a dynamic pipe. It acts as the input side (OutputStream) itself. Use getReadEnd() to retrieve the output side.

Method Detail

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

getReadEnd

public InputStream getReadEnd()

Returns:

the read end (InputStream) of the pipe.

propagateException

public void propagateException(IOException ioException)
                        throws IOException

Propagates an IOException to the reading site.

Parameters:

ioException - exception to propagate

Throws:

IOException - if an I/O Error occurs

Since:

jadice server 4.3.1.0

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException