Trait Input 

pub trait Input {
    type Data;
    type Ack;

    // Required method
    fn run(self) -> Result<(), Error>;
}

A trait for a data source that produces messages of type Data.

Required Associated Types

type Data

type Ack

Required Methods

fn run(self) -> Result<(), Error>

Fetches events and send them as Data. It also receives and processes Ack, which acknowledges the receipt of a certain Data.

Errors

Returns an error if it fails to fetch events, or receives an invalid Data or Ack.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T: Read> Input for eventio::mbox::Input<T>

type Data = BareEvent

type Ack = usize

impl<T: Read> Input for eventio::text::Input<T>

type Data = BareEvent

type Ack = usize