ExecutionPlane.LineFraming (execution_plane v0.1.0)

Incremental newline framing for stdout and stderr stream handling.

Summary

t()

Returns true when there is no buffered partial line.

flush(state)

Flushes a trailing partial fragment as a final line.

Creates a new framing state.

Pushes a binary chunk into the framer and returns complete lines.

@type t() :: %ExecutionPlane.LineFraming{buffer: binary()}

@spec empty?(t()) :: boolean()

Returns true when there is no buffered partial line.

@spec flush(t()) :: {[binary()], t()}

Flushes a trailing partial fragment as a final line.

@spec new(binary()) :: t()

Creates a new framing state.

@spec push(t(), iodata()) :: {[binary()], t()}

Pushes a binary chunk into the framer and returns complete lines.