Module org.yamcs.core

Package org.yamcs.yarch

Class InternalStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.InternalStream

public class InternalStream
extends Stream

The simplest stream implementation, just passes data to the subscribers

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
InternalStream(YarchDatabaseInstance dict, String name, TupleDefinition definition)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
void	doStart()	Start emitting tuples.

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, toString

Methods inherited from class java.lang.Object

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

Constructor Details

InternalStream

public InternalStream(YarchDatabaseInstance dict,
 String name,
 TupleDefinition definition)

Method Details

doClose

protected 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