Type Alias QueryInput 

pub type QueryInput = Input;

An input stream intended to contain a SPARQL query.

Aliased Type

pub enum QueryInput {
    Ignored,
    AsyncRead(Box<dyn AsyncRead + Sync + Unpin + Send>),
    Jsonl(Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>),
}

Variants

Ignored

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

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

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(Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>)

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.