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 StreamHandler
StreamException
public void packetDescriptor(PacketDescriptor pd) throws StreamException
packetDescriptor
in interface StreamHandler
StreamException
public void resizeBuffer(int size) throws StreamException
StreamException
public void streamClosed(StreamDescriptor sd) throws StreamException
streamClosed
in interface StreamHandler
StreamException
public void streamDescriptor(StreamDescriptor sd) throws StreamException
streamDescriptor
in interface StreamHandler
StreamException
public void streamException(StreamException se) throws StreamException
streamException
in interface StreamHandler
StreamException
public void flush() throws StreamException
StreamException
public void streamComment(StreamComment sc) throws StreamException
streamComment
in interface StreamHandler
StreamException