org.yamcs.web.rest

Class RestStreamSubscriber

java.lang.Object

org.yamcs.web.rest.RestStreamSubscriber

All Implemented Interfaces:

StreamSubscriber

Direct Known Subclasses:

StreamToChunkedTransferEncoder

public abstract class RestStreamSubscriber
extends Object
implements StreamSubscriber

Constructor Summary

Constructors

Constructor and Description
RestStreamSubscriber()
RestStreamSubscriber(long pos, int limit) process a paged set of stream data data

Method Summary

Modifier and Type	Method and Description
void	onTuple(Stream stream, Tuple tuple)
abstract void	processTuple(Stream stream, Tuple tuple)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.yarch.StreamSubscriber

streamClosed

Constructor Detail

RestStreamSubscriber

public RestStreamSubscriber(long pos,
                            int limit)

process a paged set of stream data data

RestStreamSubscriber

public RestStreamSubscriber()

Method Detail

onTuple

public void onTuple(Stream stream,
                    Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

processTuple

public abstract void processTuple(Stream stream,
                                  Tuple tuple)