Struct Reader 

pub struct Reader { /* private fields */ }

Available on crate feature std only.

An external reader that imports input data into an RDF dataset.

This is a program-pattern wrapper, not an implementation of an I/O reader trait. Input parsing and conversion are performed by the external program. Execution uses the concurrent streaming behavior described in crate::programs.

Implementations

impl Reader

pub fn new( program: impl AsRef<OsStr>, input: AnyInput, output: GraphOutput, options: ReaderOptions, ) -> Self

Configures a reader without starting it.

Adds any configured --input=<format> and --output=<format> arguments, followed by options.other. The input and output values select stdin and stdout; stderr is captured for failure diagnostics.

pub async fn execute(&mut self) -> ReaderResult

Starts a child and returns its live JSONL graph stream.

After successful spawning, input ownership moves into the stream, which feeds it concurrently when polled. Subsequent executions have no source input.

Errors

Spawn failures are returned directly; input, output, wait, and exit failures are stream items. Consume the stream to completion to check process success.

impl Reader

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

Sets batching thresholds for captured JSONL output. This does not change subprocess arguments, native pipeline edges, or listing limits. The default policy is crate::BatchOptions::default.

Trait Implementations

impl Debug for Reader

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

Formats the value using the given formatter.

impl Execute<Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>> for Reader

type Error = ExecutorError

The implementation-specific error returned directly by execution.

fn execute<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ReaderResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes the operation using its current input and configuration.

impl GraphProducer for Reader

impl PipelineProgram for Reader

impl Reader<Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>> for Reader