org.yamcs.yarch

Class InputStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.InputStream

All Implemented Interfaces:

Runnable, Stream

public class InputStream
extends AbstractStream
implements Runnable

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

Method Summary

Modifier and Type	Method and Description
void	doClose()
int	getPort()
void	run()
void	start() Start emitting tuples.
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

InputStream

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

Throws:

YarchException

Method Detail

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

getPort

public int getPort()

run

public void run()

Specified by:

run in interface Runnable

doClose

public void doClose()

Specified by:

doClose in class AbstractStream

toString

public String toString()

Overrides:

toString in class AbstractStream