Enum Input 

pub enum Input {
    Ignored,
    AsyncRead(Box<dyn AsyncRead + Send + Sync + Unpin>),
    Jsonl(JsonlStream),
}

The source of bytes to supply to a child’s stdin.

Program wrappers configure the child’s stdin from this value and feed the resulting pipe during execution. Graph-output runners transfer ownership of their input into the returned stream. Buffered runners consume it in place. Repeated executions never replay bytes that have already been read. Early exit or cancellation can leave input partially consumed, including a partly written record; reusing it does not guarantee record-boundary resumption.

With std enabled, conversion to Stdio only selects null or piped stdin; it does not transfer bytes. The consuming conversion also drops any stored reader or batch stream. Use Input::as_stdio to preserve the source for execution.

Variants

Ignored

Supplies no bytes by configuring stdin to read from the null device.

AsyncRead(Box<dyn AsyncRead + Send + Sync + Unpin>)

Supplies bytes from an owned asynchronous reader through a stdin pipe.

The reader must support use across asynchronous tasks (Send + Sync) and unpinned I/O (Unpin). Its contents are omitted from debug output.

Jsonl(JsonlStream)

Available on crate feature std only.

Supplies JSONL batches, applying backpressure and propagating source errors. Contiguous terminated batches are written directly; fragmented batches use bounded vectored I/O when supported, or a reusable copy buffer. Batch boundaries are not encoded on the wire. Empty batches are ignored. Existing line endings are preserved; an LF is appended to any line that does not end in LF so adjacent records cannot run together. An empty line therefore writes a blank line. Line constructors enforce framing; UTF-8, JSON, and RDF mapping profiles are not validated here.

Implementations

impl Input

pub fn as_stdio(&self) -> Stdio

Available on crate feature std only.

Selects the child’s stdin configuration without consuming this input.

Returns null stdin for Ignored and a pipe for AsyncRead and Jsonl. The caller must still feed the child’s pipe after spawning it.

pub fn into_jsonl(self) -> Self

Available on crate feature std only.

Adapts byte input to batched JSONL input using default thresholds.

Wraps AsyncRead using crate::jsonl_batches; other variants are returned unchanged. Adaptation is lazy and performs no I/O. When fed to a child, a final unterminated line gains an LF as described by Jsonl.

pub fn into_jsonl_with_batching(self, options: BatchOptions) -> Self

Available on crate feature std only.

Adapts an asynchronous reader into JSONL batches with the supplied policy. Existing batch streams and ignored input are returned unchanged. To rebatch a stream, combine crate::flatten_batches and crate::batch_lines.

Trait Implementations

impl Debug for Input

fn fmt(&self, __derive_more_f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Into<Stdio> for Input

Available on crate feature std only.

fn into(self) -> Stdio

Converts this type into the (usually inferred) input type.