DataPipe

DataPipe is a pipeline of data processors, each accept some data, process it, and put result to next element in line. This class used to combine different Transfer- and Content- encodings. For example: unchunk transfer-encoding "chunnked", and uncompress Content-Encoding "gzip".

class DataPipe : DataPipeIface!E(

) {

DataPipeIface!(E)[] pipe;

Buffer!E buffer;

void insert(DataPipeIface!E p);

E[][] process(DataPipeIface!E p, E[][] data);

void putNoCopy(E[] data);

}

Members

Functions

empty bool empty(): Test if internal buffer is empty
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.
get E[] get(): Get what was collected in internal buffer and clear it.
getNoCopy E[][] getNoCopy(): get without datamove. but user receive [][]
insert void insert(DataPipeIface!E p): Append data processor to pipeline
process E[][] process(DataPipeIface!E p, E[][] data): Undocumented in source. Be warned that the author may not have intended to support it.
putNoCopy void putNoCopy(E[] data): Process next data portion. Data passed over pipeline and store result in buffer.

Variables

buffer Buffer!E buffer;: Undocumented in source.
pipe DataPipeIface!(E)[] pipe;: Undocumented in source.

DataPipe

Members

Functions

Variables

Meta

Source