Trait SignalReceiver

pub trait SignalReceiver {
    // Required method
    fn signal<'life0, 'async_trait>(
        &'life0 mut self,
        signal: Signal,
    ) -> Pin<Box<dyn Future<Output = Result<(), PipelineErrorKind>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;
}

Providers a way for the pipeline to accept a signal from the driver.

Required Methods

fn signal<'life0, 'async_trait>( &'life0 mut self, signal: Signal, ) -> Pin<Box<dyn Future<Output = Result<(), PipelineErrorKind>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Receives a signal from the driver.

Implementors

impl<DAP, P> SignalReceiver for L1Retrieval<DAP, P>

where DAP: DataAvailabilityProvider + Send, P: L1RetrievalProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send,

impl<F> SignalReceiver for L1Traversal<F>

where F: ChainProvider + Send,

impl<P> SignalReceiver for BatchValidator<P>

where P: NextBatchProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

impl<P> SignalReceiver for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

impl<P> SignalReceiver for ChannelBank<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

impl<P> SignalReceiver for ChannelProvider<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

impl<P> SignalReceiver for ChannelReader<P>

where P: ChannelReaderProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Send,

impl<P> SignalReceiver for FrameQueue<P>

where P: FrameQueueProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

impl<P, AB> SignalReceiver for AttributesQueue<P, AB>

where P: AttributesProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug, AB: AttributesBuilder + Send + Debug,

impl<P, BF> SignalReceiver for BatchQueue<P, BF>

where P: NextBatchProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug, BF: L2ChainProvider + Send + Debug,

impl<P, BF> SignalReceiver for BatchStream<P, BF>

where P: BatchStreamProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Send, BF: L2ChainProvider + Send + Debug,

impl<P, F> SignalReceiver for BatchProvider<P, F>

where P: NextBatchProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug, F: L2ChainProvider + Clone + Send + Debug,

impl<S, P> SignalReceiver for DerivationPipeline<S, P>

where S: NextAttributes + SignalReceiver + OriginProvider + OriginAdvancer + Debug + Send + Sync, P: L2ChainProvider + Send + Sync + Debug,