Package com.levigo.jadice.server.core

Class BufferedStreamBundle

java.lang.Object

com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle

com.levigo.jadice.server.core.BufferedStreamBundle

All Implemented Interfaces:

StreamBundle, Iterable<Stream>, Iterator<Stream>

public class BufferedStreamBundle
extends com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle

Extends StreamBundle for usage of BufferManager and BufferManagerDynamicPipe

Constructor Summary

Constructors

Constructor	Description
BufferedStreamBundle()
BufferedStreamBundle(com.levigo.jadice.bm.internal.BufferManager manager)

Method Summary

Modifier and Type	Method	Description
void	addStream(Stream s)	Add a Stream to this bundle.
OutputStream	addStream(StreamDescriptor type)	Convenience method: add a DynamicPipe for the given StreamDescriptor, and return as the OutputStream the write end of the pipe.
com.levigo.jadice.bm.internal.BufferManager	getManager()

Methods inherited from class com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle

abort, addStream, complete, hasNext, isComplete, iterator, next, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

BufferedStreamBundle

public BufferedStreamBundle()

BufferedStreamBundle

public BufferedStreamBundle(com.levigo.jadice.bm.internal.BufferManager manager)

Method Detail

getManager

public com.levigo.jadice.bm.internal.BufferManager getManager()

addStream

public void addStream(Stream s)

Description copied from interface: StreamBundle

Add a Stream to this bundle.

Specified by:

addStream in interface StreamBundle

Overrides:

addStream in class com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle

Parameters:

s - the Stream to be added

addStream

public OutputStream addStream(StreamDescriptor type)
                       throws IOException

Description copied from interface: StreamBundle

Convenience method: add a DynamicPipe for the given StreamDescriptor, and return as the OutputStream the write end of the pipe.

Specified by:

addStream in interface StreamBundle

Overrides:

addStream in class com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle

Parameters:

type - the associated StreamDescriptor

Returns:

output stream

Throws:

IOException - if an I/O Error occurs