org.yamcs.yarch

Class SpeedLimitStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.SpeedLimitStream

All Implemented Interfaces:

Stream, StreamSubscriber

public class SpeedLimitStream
extends AbstractStream
implements StreamSubscriber

Field Summary

Fields

Modifier and Type	Field and Description
static 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.AbstractStream

log, name, outputDefinition, state, subscribers, ydb

Fields inherited from interface org.yamcs.yarch.Stream

QUITTING, RUNNING, SETUP

Constructor Summary

Constructors

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

Method Summary

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

Field Detail

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 Detail

SpeedLimitStream

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

Method Detail

setSubscribedStream

public void setSubscribedStream(Stream s)

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

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 AbstractStream

doClose

protected void doClose()

Specified by:

doClose in class AbstractStream

changeSpeed

public void changeSpeed(SpeedSpec speedSpec)