org.yamcs.web.rest

Class StreamToChunkedCSVEncoder

java.lang.Object

org.yamcs.web.rest.RestStreamSubscriber

org.yamcs.web.rest.StreamToChunkedTransferEncoder

org.yamcs.web.rest.StreamToChunkedCSVEncoder

All Implemented Interfaces:

StreamSubscriber

public abstract class StreamToChunkedCSVEncoder
extends StreamToChunkedTransferEncoder

Facilitates sending CSV data with chunked transfer encoding. It wraps the ByteBufOutputSteam with a CSVWriter

Field Summary

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

bufOut, contentType, failed

Constructor Summary

Constructors

Constructor and Description
StreamToChunkedCSVEncoder(RestRequest req)

Method Summary

Modifier and Type	Method and Description
protected void	closeBufferOutputStream()
String[]	getCSVHeader()
void	processTuple(Tuple tuple, io.netty.buffer.ByteBufOutputStream bufOut)
abstract void	processTuple(Tuple tuple, com.csvreader.CsvWriter csvWriter)
protected void	resetBuffer()

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

processTuple, 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

StreamToChunkedCSVEncoder

public StreamToChunkedCSVEncoder(RestRequest req)
                          throws HttpException

Throws:

HttpException

Method Detail

resetBuffer

protected void resetBuffer()

Overrides:

resetBuffer in class StreamToChunkedTransferEncoder

closeBufferOutputStream

protected void closeBufferOutputStream()
                                throws IOException

Overrides:

closeBufferOutputStream in class StreamToChunkedTransferEncoder

Throws:

IOException

processTuple

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

Specified by:

processTuple in class StreamToChunkedTransferEncoder

Throws:

IOException

processTuple

public abstract void processTuple(Tuple tuple,
                                  com.csvreader.CsvWriter csvWriter)
                           throws IOException

Throws:

IOException

getCSVHeader

public String[] getCSVHeader()