Trait chewdata::step::Step

source ·

pub trait Step: Send + Sync + StepClone {
    // Required methods
    fn exec<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn set_receiver(&mut self, receiver: Receiver<Context>);
    fn receiver(&self) -> Option<&Receiver<Context>>;
    fn set_sender(&mut self, sender: Sender<Context>);
    fn sender(&self) -> Option<&Sender<Context>>;

    // Provided methods
    fn number(&self) -> usize { ... }
    fn name(&self) -> String { ... }
    fn send<'life0, 'life1, 'async_trait>(
        &'life0 self,
        context: &'life1 Context
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn receive<'step, 'async_trait>(
        &'step self
    ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Context> + Send + 'step>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'step: 'async_trait { ... }
}