public class StreamProducer extends java.lang.Object implements StreamHandler
| Constructor and Description |
|---|
StreamProducer(java.nio.channels.WritableByteChannel stream)
Creates a new instance of StreamProducer
|
| Modifier and Type | Method and Description |
|---|---|
void |
flush() |
void |
packet(PacketDescriptor pd,
Datum xTag,
DatumVector[] vectors) |
void |
packetDescriptor(PacketDescriptor pd) |
void |
resizeBuffer(int size) |
void |
streamClosed(StreamDescriptor sd) |
void |
streamComment(StreamComment sc) |
void |
streamDescriptor(StreamDescriptor sd) |
void |
streamException(StreamException se) |
public StreamProducer(java.nio.channels.WritableByteChannel stream)
public void packet(PacketDescriptor pd, Datum xTag, DatumVector[] vectors) throws StreamException
packet in interface StreamHandlerStreamExceptionpublic void packetDescriptor(PacketDescriptor pd) throws StreamException
packetDescriptor in interface StreamHandlerStreamExceptionpublic void resizeBuffer(int size)
throws StreamException
StreamExceptionpublic void streamClosed(StreamDescriptor sd) throws StreamException
streamClosed in interface StreamHandlerStreamExceptionpublic void streamDescriptor(StreamDescriptor sd) throws StreamException
streamDescriptor in interface StreamHandlerStreamExceptionpublic void streamException(StreamException se) throws StreamException
streamException in interface StreamHandlerStreamExceptionpublic void flush()
throws StreamException
StreamExceptionpublic void streamComment(StreamComment sc) throws StreamException
streamComment in interface StreamHandlerStreamException