Module org.yamcs.core

Package org.yamcs.yarch

Class InternalStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.InternalStream

All Implemented Interfaces:

StreamSubscriber

public class InternalStream
extends Stream
implements StreamSubscriber

Stream created by the "create stream statement"

It has an execution context associated and is responsible for closing it when the stream closes.

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(ExecutionContext ctx, String name, TupleDefinition definition)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
void	doStart()	Start emitting tuples.
void	onTuple(Stream stream, Tuple tuple)
void	setInner(Stream inner)
void	streamClosed(Stream stream)

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(ExecutionContext ctx,
 String name,
 TupleDefinition definition)

Method Details

setInner

public void setInner(Stream inner)

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

onTuple

public void onTuple(Stream stream,
 Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber