Trait dashpipe::InputChannel

pub trait InputChannel {
    fn start(
        &self
    ) -> Result<Box<dyn Stream<Item = String, Error = Error>>, DashPipeError>;
}

Required methods

fn start(
    &self
) -> Result<Box<dyn Stream<Item = String, Error = Error>>, DashPipeError>

Loading content...

Implementors

impl InputChannel for KafkaInput

fn start(
    &self
) -> Result<Box<dyn Stream<Item = String, Error = Error>>, DashPipeError>

impl InputChannel for NatsInput

fn start(
    &self
) -> Result<Box<dyn Stream<Item = String, Error = Error>>, DashPipeError>

impl InputChannel for StdinInput

fn start(
    &self
) -> Result<Box<dyn Stream<Item = String, Error = Error>>, DashPipeError>

Loading content...