org.yamcs.yarch

Class OutputStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.OutputStream

All Implemented Interfaces:

Stream, StreamSubscriber

public class OutputStream
extends AbstractStream
implements StreamSubscriber

Field Summary

Fields inherited from class org.yamcs.yarch.AbstractStream

log, name, outputDefinition, state, subscribers, ydb

Fields inherited from interface org.yamcs.yarch.Stream

QUITTING, RUNNING, SETUP

Constructor Summary

Constructors

Constructor and Description
OutputStream(YarchDatabase dict, String name, TupleDefinition def)

Method Summary

Modifier and Type	Method and Description
void	doClose()
int	getPort()
void	onTuple(Stream s, Tuple t)
void	setSubscribedStream(Stream s)
void	start() Start emitting tuples.
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.AbstractStream

addSubscriber, close, emitTuple, getColumnDefinition, getDefinition, getName, getNumEmittedTuples, getState, getSubscriberCount, getSubscribers, removeSubscriber, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputStream

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

Throws:

YarchException

Method Detail

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 AbstractStream

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

toString

public String toString()

Overrides:

toString in class AbstractStream