org.das2.stream
Class StreamProducer

java.lang.Object
  org.das2.stream.StreamProducer

All Implemented Interfaces:

StreamHandler

public class StreamProducer
extends java.lang.Object
implements StreamHandler

Constructor Summary

StreamProducer(java.nio.channels.WritableByteChannel stream)
Creates a new instance of StreamProducer

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamProducer

public StreamProducer(java.nio.channels.WritableByteChannel stream)

Creates a new instance of StreamProducer

Method Detail

packet

public void packet(PacketDescriptor pd,
                   Datum xTag,
                   DatumVector[] vectors)
            throws StreamException

Specified by:

packet in interface StreamHandler

Throws:

StreamException

packetDescriptor

public void packetDescriptor(PacketDescriptor pd)
                      throws StreamException

Specified by:

packetDescriptor in interface StreamHandler

Throws:

StreamException

resizeBuffer

public void resizeBuffer(int size)
                  throws StreamException

Throws:

StreamException

streamClosed

public void streamClosed(StreamDescriptor sd)
                  throws StreamException

Specified by:

streamClosed in interface StreamHandler

Throws:

StreamException

streamDescriptor

public void streamDescriptor(StreamDescriptor sd)
                      throws StreamException

Specified by:

streamDescriptor in interface StreamHandler

Throws:

StreamException

streamException

public void streamException(StreamException se)
                     throws StreamException

Specified by:

streamException in interface StreamHandler

Throws:

StreamException

flush

public void flush()
           throws StreamException

Throws:

StreamException

streamComment

public void streamComment(StreamComment sc)
                   throws StreamException

Specified by:

streamComment in interface StreamHandler

Throws:

StreamException