org.yamcs.web.rest

Class StreamToChunkedProtobufEncoder<T extends com.google.protobuf.MessageLite>

java.lang.Object

org.yamcs.web.rest.RestStreamSubscriber

org.yamcs.web.rest.StreamToChunkedTransferEncoder

org.yamcs.web.rest.StreamToChunkedProtobufEncoder<T>

All Implemented Interfaces:

StreamSubscriber

public abstract class StreamToChunkedProtobufEncoder<T extends com.google.protobuf.MessageLite>
extends StreamToChunkedTransferEncoder

Facilitates sending protobuf messages with chunked transfer encoding

Field Summary

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

bufOut, contentType, failed

Constructor Summary

Constructors

Constructor and Description
StreamToChunkedProtobufEncoder(RestRequest req, io.protostuff.Schema<T> schema)

Method Summary

Modifier and Type	Method and Description
abstract T	mapTuple(Tuple tuple)
void	processTuple(Tuple tuple, io.netty.buffer.ByteBufOutputStream bufOut)

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

closeBufferOutputStream, processTuple, resetBuffer, streamClosed

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

onTuple

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamToChunkedProtobufEncoder

public StreamToChunkedProtobufEncoder(RestRequest req,
                                      io.protostuff.Schema<T> schema)
                               throws HttpException

Throws:

HttpException

Method Detail

processTuple

public void processTuple(Tuple tuple,
                         io.netty.buffer.ByteBufOutputStream bufOut)
                  throws IOException

Specified by:

processTuple in class StreamToChunkedTransferEncoder

Throws:

IOException

mapTuple

public abstract T mapTuple(Tuple tuple)