org.yamcs.yarch

Interface Stream

All Known Implementing Classes:

AbstractStream, AbstractTableReaderStream, CfTableReaderStream, HistogramReaderStream, InkeyTableReaderStream, InputStream, InternalStream, MergeStream, OutputStream, SelectStream, SpeedLimitStream

public interface Stream

Field Summary

Fields

Modifier and Type	Field and Description
static int	QUITTING
static int	RUNNING
static int	SETUP

Method Summary

Modifier and Type	Method and Description
void	addSubscriber(StreamSubscriber s)
void	close() Closes the stream by: send the streamClosed signal to all subscribed clients
void	emitTuple(Tuple t)
ColumnDefinition	getColumnDefinition(String colName)
TupleDefinition	getDefinition()
String	getName()
long	getNumEmittedTuples()
int	getState()
int	getSubscriberCount()
Collection<StreamSubscriber>	getSubscribers()
void	removeSubscriber(StreamSubscriber s)
void	setName(String streamName)
void	start() Start emitting tuples.

Field Detail

SETUP

static final int SETUP

See Also:

Constant Field Values

RUNNING

static final int RUNNING

See Also:

Constant Field Values

QUITTING

static final int QUITTING

See Also:

Constant Field Values

Method Detail

start

void start()

Start emitting tuples.

getDefinition

TupleDefinition getDefinition()

emitTuple

void emitTuple(Tuple t)

getName

String getName()

setName

void setName(String streamName)

addSubscriber

void addSubscriber(StreamSubscriber s)

removeSubscriber

void removeSubscriber(StreamSubscriber s)

getColumnDefinition

ColumnDefinition getColumnDefinition(String colName)

close

void close()

Closes the stream by: send the streamClosed signal to all subscribed clients

getState

int getState()

getNumEmittedTuples

long getNumEmittedTuples()

getSubscriberCount

int getSubscriberCount()

getSubscribers

Collection<StreamSubscriber> getSubscribers()