Enum WorkerReader 

pub enum WorkerReader<R> {
    Yson(JobReader<R>),
    Skiff(SkiffJobReader<R>),
}

A reader selected by the operation’s input DataFormat.

Variants

Yson(JobReader<R>)

A YSON job stream.

Skiff(SkiffJobReader<R>)

A schema-described Skiff job stream.

Implementations

impl WorkerReader<BufReader<Stdin>>

pub fn from_stdin(format: DataFormat) -> Result<Self>

Reads stdin using the operation’s selected input format.

Buffered, because this constructor may end up on the Skiff side, which reads field by field — see skiff::STDIN_BUFFER_BYTES. The YSON side asks for a whole buffer at a time and is handed the descriptor’s bytes without a second copy.

Errors

Returns an error if the format is unknown to this runtime or a Skiff schema is not suitable for job input.

impl<R: Read> WorkerReader<R>

pub fn new(input: R, format: DataFormat) -> Result<Self>

Creates a worker input reader selected by format.

Errors

Returns an error if the format is unknown to this runtime or a Skiff schema is not suitable for job input.

pub fn next_event(&mut self) -> Result<Option<WorkerEvent<'_>>>

Returns the next row or control event, or None at clean end of input.

A returned YSON event borrows the reader’s buffer; process it before calling this method again. Skiff rows are owned.

Trait Implementations

impl<R: Debug> Debug for WorkerReader<R>

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

Formats the value using the given formatter.