Package org.yamcs.yarch

Class SpeedLimitStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.SpeedLimitStream

All Implemented Interfaces:

StreamSubscriber

public class SpeedLimitStream
extends Stream
implements StreamSubscriber

Nested Class Summary

Nested classes/interfaces inherited from class org.yamcs.yarch.Stream

Stream.ExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final long	MAX_WAIT_TIME	maximum time to wait if SPEED is ORIGINAL meaning that if there is a gap in the data longer than this, we continue)

Fields inherited from class org.yamcs.yarch.Stream

log, name, outputDefinition, QUITTING, RUNNING, SETUP, state, subscribers, ydb

Constructor Summary

Constructors

Constructor	Description
SpeedLimitStream(YarchDatabaseInstance dict, String name, TupleDefinition definition, SpeedSpec speedSpec)

Method Summary

Modifier and Type	Method	Description
void	changeSpeed(SpeedSpec speedSpec)
protected void	doClose()
void	doStart()	Start emitting tuples.
void	onTuple(Stream s, Tuple t)
void	setSpeedSpec(SpeedSpec speedSpec)
void	setSubscribedStream(Stream s)
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.Stream

addSubscriber, close, emitTuple, exceptionHandler, getColumnDefinition, getDataCount, getDefinition, getName, getState, getSubscriberCount, getSubscribers, isClosed, isRunning, quitting, removeSubscriber, setName, start

Methods inherited from class java.lang.Object

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

Field Details

MAX_WAIT_TIME

public static final long MAX_WAIT_TIME

maximum time to wait if SPEED is ORIGINAL meaning that if there is a gap in the data longer than this, we continue)

See Also:

• Constant Field Values

Constructor Details

SpeedLimitStream

public SpeedLimitStream(YarchDatabaseInstance dict,
 String name,
 TupleDefinition definition,
 SpeedSpec speedSpec)

Method Details

setSubscribedStream

public void setSubscribedStream(Stream s)

doStart

public void doStart()

Description copied from class: Stream

Start emitting tuples.

Specified by:

doStart in class Stream

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

setSpeedSpec

public void setSpeedSpec(SpeedSpec speedSpec)

toString

public String toString()

Overrides:

toString in class Stream

doClose

protected void doClose()

Specified by:

doClose in class Stream

changeSpeed

public void changeSpeed(SpeedSpec speedSpec)