Package org.yamcs.yarch

Class OutputStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.OutputStream

All Implemented Interfaces:

StreamSubscriber

public class OutputStream
extends Stream
implements StreamSubscriber

Nested Class Summary

Nested classes/interfaces inherited from class org.yamcs.yarch.Stream

Stream.ExceptionHandler

Field Summary

Fields inherited from class org.yamcs.yarch.Stream

log, name, outputDefinition, QUITTING, RUNNING, SETUP, state, subscribers, ydb

Constructor Summary

Constructors

Constructor	Description
OutputStream(YarchDatabaseInstance dict, String name, TupleDefinition def)

Method Summary

Modifier and Type	Method	Description
void	doClose()
void	doStart()	Start emitting tuples.
int	getPort()
void	onTuple(Stream s, Tuple t)
void	setSubscribedStream(Stream s)
void	streamClosed(Stream stream)	Called when the subcribed stream is closed we close this stream also.
String	toString()

Methods inherited from class org.yamcs.yarch.Stream

addSubscriber, close, emitTuple, exceptionHandler, getColumnDefinition, getDataCount, getDefinition, getName, getState, getSubscriberCount, getSubscribers, isClosed, isRunning, quitting, removeSubscriber, setName, start

Methods inherited from class java.lang.Object

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

Constructor Details

OutputStream

public OutputStream(YarchDatabaseInstance dict,
 String name,
 TupleDefinition def)
             throws YarchException

Throws:

YarchException

Method Details

setSubscribedStream

public void setSubscribedStream(Stream s)

getPort

public int getPort()

onTuple

public void onTuple(Stream s,
 Tuple t)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Called when the subcribed stream is closed we close this stream also.

Specified by:

streamClosed in interface StreamSubscriber

doClose

public void doClose()

Specified by:

doClose in class Stream

doStart

public void doStart()

Description copied from class: Stream

Start emitting tuples.

Specified by:

doStart in class Stream

toString

public String toString()

Overrides:

toString in class Stream