org.yamcs.web.rest

Class ParameterReplayToChunkedProtobufEncoder

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.ParameterReplayToChunkedProtobufEncoder

All Implemented Interfaces:

ParameterWithIdConsumer

public class ParameterReplayToChunkedProtobufEncoder
extends ParameterReplayToChunkedTransferEncoder

Facilitates working with chunked transfer of gpb parameters

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
ParameterReplayToChunkedProtobufEncoder(RestRequest req)

Method Summary

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

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

closeBufferOutputStream, onParameterData, replayFinished, resetBuffer

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

ParameterReplayToChunkedProtobufEncoder

public ParameterReplayToChunkedProtobufEncoder(RestRequest req)
                                        throws HttpException

Throws:

HttpException

Method Detail

processParameterData

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

Specified by:

processParameterData in class ParameterReplayToChunkedTransferEncoder

Throws:

IOException