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 put(E[] data);

void put(Buffer!E buff);

E[] get();

bool empty();

void flush();

}

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.
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.
put void put(E[] data): Process next data portion. Data passed over pipeline and result stored in buffer.
put void put(Buffer!E buff): 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