- byChunk
auto byChunk(S schema, size_t chunk_size)
auto byChunk(S schema, E[] buf)
Returns a range that reads from the pipeline one chunk at a time.
- byLine
auto byLine(S schema, Terminator terminator, Flag!"keepTerminator" keep_terminator)
Returns a range that reads from the pipeline one line at a time.
- copy
auto copy(S schema, R target)
Copies all data from the pipeline instantiated from schema to output range target.
- pipeFromArray
auto pipeFromArray(const(E)[] array)
Undocumented in source. Be warned that the author may not have intended to support it.
- pipeFromInputRange
auto pipeFromInputRange(R r)
Undocumented in source. Be warned that the author may not have intended to support it.
- testOutputRange
void testOutputRange()
Undocumented in source. Be warned that the author may not have intended to support it.
This module contains pipes used to convert between ranges and pipelines.
Built-in arrays and input ranges can be used directly as pipeline sources. For arrays of characters no auto-decoding is performed.
Pipelines can be read from as input ranges by element (flod.pipeline.Schema.opSlice), by chunk (byChunk) or by line (byLine).