Struct protoflow_blocks::ReadStdin

pub struct ReadStdin {
    pub output: OutputPort<Bytes>,
    pub buffer_size: usize,
}

A block that reads bytes from standard input (aka stdin).

Block Diagram

block-beta
    columns 4
    ReadStdin space:2 Sink
    ReadStdin-- "output" -->Sink

    classDef block height:48px,padding:8px;
    classDef hidden visibility:none;
    class ReadStdin block
    class Sink hidden

Sequence Diagram

sequenceDiagram
    autonumber
    participant ReadStdin as ReadStdin block
    participant ReadStdin.output as ReadStdin.output port
    participant BlockA as Another block

    ReadStdin-->>BlockA: Connect

    loop ReadStdin process
        ReadStdin->>ReadStdin: Read bytes from standard input
        ReadStdin->>BlockA: Message (Bytes)
    end

    ReadStdin-->>ReadStdin.output: Close
    ReadStdin-->>BlockA: Disconnect

Examples

Using the block in a system

System::build(|s| {
    let stdin = s.read_stdin();
    let stdout = s.write_stdout();
    s.connect(&stdin.output, &stdout.input);
});

Running the block via the CLI

$ protoflow execute ReadStdin < input.txt

$ protoflow execute ReadStdin buffer-size=1024 < input.txt

Fields

output: OutputPort<Bytes>

The output message stream.

buffer_size: usize

The maximum number of bytes to read at a time.

Implementations

impl ReadStdin

pub fn new(output: OutputPort<Bytes>) -> Self

pub fn with_params( output: OutputPort<Bytes>, buffer_size: Option<usize>, ) -> Self

Trait Implementations

impl Block for ReadStdin

fn execute(&mut self, runtime: &dyn BlockRuntime) -> BlockResult

Executes this block’s computation.

fn prepare(&mut self, _runtime: &dyn BlockRuntime) -> Result<(), BlockError>

Prepares this block for execution.

impl BlockDescriptor for ReadStdin

fn inputs(&self) -> Vec<PortDescriptor>

A description of this block’s input ports.

fn outputs(&self) -> Vec<PortDescriptor>

A description of this block’s output ports.

fn name(&self) -> Option<String>

The machine-readable name of this block.

fn label(&self) -> Option<String>

A human-readable label for this block.

impl Clone for ReadStdin

fn clone(&self) -> ReadStdin

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Definition for ReadStdin

fn is_variation(&self) -> bool

impl Element for ReadStdin

fn id(&self) -> Option<&str>

The unique element ID, if any.

fn alias_ids(&self) -> Vec<&str>

Various alternative identifiers for this Element.

fn name(&self) -> Option<&str>

The name of the element.

fn short_name(&self) -> Option<&str>

The short name of the element, if any.

fn is_library_element(&self) -> bool

Whether this Element is contained in the ownership tree of a library model.

fn owner(&self) -> Option<&dyn Element>

The owner of this Element, if any.

fn owning_namespace(&self) -> Option<&dyn Namespace>

The Namespace that owns this Element, if any.

fn owning_relationship(&self) -> Option<&dyn Relationship>

The Relationship for which this Element is an owned_related_element, if any.

fn qualified_name(&self) -> Option<QualifiedName>

impl Namespace for ReadStdin

fn names_of(&self, _element: &dyn Element) -> Vec<String>

impl OccurrenceDefinition for ReadStdin

fn is_individual(&self) -> bool

impl StdioSystem for ReadStdin

fn build_system(_config: StdioConfig) -> Result<System, StdioError>

impl Type for ReadStdin

fn is_abstract(&self) -> bool

fn is_sufficient(&self) -> bool

fn is_conjugated(&self) -> bool

fn specializes(&self, _supertype: &Self) -> bool

impl BlockDefinition for ReadStdin

impl Class for ReadStdin

impl Classifier for ReadStdin

impl ItemDefinition for ReadStdin

impl PartDefinition for ReadStdin

impl Structure for ReadStdin