Trait mmids_core::workflows::steps::ExternalStreamHandler

source · [−]
pub trait ExternalStreamHandler {
    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

Implementors