Skip to content

PipeReceiver

Receives values from a strand pipe.

Created for connections between strand.pipeline stages and for a strand.stream strand's implicit input; it cannot be constructed directly.

Both framing methods reconfigure the receiver in place. They do not alter values sent directly by another Do pipeline stage.

Inherits from: std.Iter[Value]

Methods

chunks() -> PipeReceiver

Selects arbitrary-sized Bin chunks when the receiver reads bytes from an external program.

close()

Closes the receiver and stops its sender.

lines() -> PipeReceiver

Selects line framing when the receiver reads bytes from an external program. This is the default.