org.yamcs.web.rest

Class ParameterReplayToChunkedCSVEncoder

java.lang.Object

com.google.common.util.concurrent.Service.Listener

org.yamcs.web.rest.RestReplayListener

org.yamcs.web.rest.RestParameterReplayListener

org.yamcs.web.rest.ParameterReplayToChunkedTransferEncoder

org.yamcs.web.rest.ParameterReplayToChunkedCSVEncoder

All Implemented Interfaces:

ParameterWithIdConsumer

public class ParameterReplayToChunkedCSVEncoder
extends ParameterReplayToChunkedTransferEncoder

Facilitates working with chunked csv transfer of parameter data. Wrap every ByteBufOutputStream with a ParameterFormatter

Field Summary

Fields inherited from class org.yamcs.web.rest.ParameterReplayToChunkedTransferEncoder

bufOut, contentType, failed, idList

Fields inherited from class org.yamcs.web.rest.RestParameterReplayListener

req

Constructor Summary

Constructors

Constructor and Description
ParameterReplayToChunkedCSVEncoder(RestRequest req, List<Yamcs.NamedObjectId> idList)

Method Summary

Modifier and Type	Method and Description
protected void	closeBufferOutputStream()
void	processParameterData(List<ParameterValueWithId> params, io.netty.buffer.ByteBufOutputStream bufOut)
protected void	resetBuffer()

Methods inherited from class org.yamcs.web.rest.ParameterReplayToChunkedTransferEncoder

onParameterData, replayFinished

Methods inherited from class org.yamcs.web.rest.RestParameterReplayListener

filter, filter, replayFailed, setNoRepeat

Methods inherited from class org.yamcs.web.rest.RestReplayListener

failed, isReplayAbortRequested, onParameterData, requestReplayAbortion, terminated, update, update

Methods inherited from class com.google.common.util.concurrent.Service.Listener

running, starting, stopping

Methods inherited from class java.lang.Object

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

Constructor Detail

ParameterReplayToChunkedCSVEncoder

public ParameterReplayToChunkedCSVEncoder(RestRequest req,
                                          List<Yamcs.NamedObjectId> idList)
                                   throws HttpException

Throws:

HttpException

Method Detail

resetBuffer

protected void resetBuffer()

Overrides:

resetBuffer in class ParameterReplayToChunkedTransferEncoder

processParameterData

public void processParameterData(List<ParameterValueWithId> params,
                                 io.netty.buffer.ByteBufOutputStream bufOut)
                          throws IOException

Specified by:

processParameterData in class ParameterReplayToChunkedTransferEncoder

Throws:

IOException

closeBufferOutputStream

protected void closeBufferOutputStream()
                                throws IOException

Overrides:

closeBufferOutputStream in class ParameterReplayToChunkedTransferEncoder

Throws:

IOException