mmids_core::workflows::steps

Trait ExternalStreamHandler

Source 
pub trait ExternalStreamHandler {
    // Required methods
    fn prepare_stream(&mut self, stream_name: &str, outputs: &mut StepOutputs);
    fn stop_stream(&mut self);
    fn handle_resolved_future(
        &mut self,
        future: Box<dyn StreamHandlerFutureResult>,
        outputs: &mut StepOutputs,
    ) -> ResolvedFutureStatus;
}
Expand description

Trait used to handle different external resources for a single stream

Required Methods§

Source

fn prepare_stream(&mut self, stream_name: &str, outputs: &mut StepOutputs)

Source

fn stop_stream(&mut self)

Source

fn handle_resolved_future( &mut self, future: Box<dyn StreamHandlerFutureResult>, outputs: &mut StepOutputs, ) -> ResolvedFutureStatus

Implementors§