org.yamcs.web.rest

Class StreamToChunkedTransferEncoder

java.lang.Object

org.yamcs.web.rest.RestStreamSubscriber

org.yamcs.web.rest.StreamToChunkedTransferEncoder

All Implemented Interfaces:

StreamSubscriber

Direct Known Subclasses:

StreamToChunkedCSVEncoder, StreamToChunkedProtobufEncoder, TableDumpEncoder

public abstract class StreamToChunkedTransferEncoder
extends RestStreamSubscriber

Reads a yamcs stream and maps it directly to an output buffer. If that buffer grows larger than the treshold size for one chunk, this will cause a chunk to be written out. Could maybe be replaced by using built-in netty functionality, but would need to investigate.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.buffer.ByteBufOutputStream	bufOut
protected MediaType	contentType
protected boolean	failed

Constructor Summary

Constructors

Constructor and Description
StreamToChunkedTransferEncoder(RestRequest req, MediaType contentType)
StreamToChunkedTransferEncoder(RestRequest req, MediaType contentType, String filename)

Method Summary

Modifier and Type	Method and Description
protected void	closeBufferOutputStream()
void	processTuple(Stream stream, Tuple tuple)
abstract void	processTuple(Tuple tuple, io.netty.buffer.ByteBufOutputStream bufOut)
protected void	resetBuffer()
void	streamClosed(Stream stream)

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

Field Detail

bufOut

protected io.netty.buffer.ByteBufOutputStream bufOut

contentType

protected MediaType contentType

failed

protected boolean failed

Constructor Detail

StreamToChunkedTransferEncoder

public StreamToChunkedTransferEncoder(RestRequest req,
                                      MediaType contentType)
                               throws HttpException

Throws:

HttpException

StreamToChunkedTransferEncoder

public StreamToChunkedTransferEncoder(RestRequest req,
                                      MediaType contentType,
                                      String filename)
                               throws HttpException

Throws:

HttpException

Method Detail

resetBuffer

protected void resetBuffer()

closeBufferOutputStream

protected void closeBufferOutputStream()
                                throws IOException

Throws:

IOException

processTuple

public void processTuple(Stream stream,
                         Tuple tuple)

Specified by:

processTuple in class RestStreamSubscriber

processTuple

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

Throws:

IOException

streamClosed

public void streamClosed(Stream stream)