pub trait BuilderTask<TYPES: NodeType>: Send + Sync {
    // Required method
    fn start(
        self: Box<Self>,
        stream: Box<dyn Stream<Item = Event<TYPES>> + Unpin + Send + 'static>
    );
}

Required Methods§

source

fn start( self: Box<Self>, stream: Box<dyn Stream<Item = Event<TYPES>> + Unpin + Send + 'static> )

Implementors§

source§

impl<TYPES: NodeType> BuilderTask<TYPES> for SimpleBuilderTask<TYPES>

source§

impl<TYPES: NodeType<Transaction = TestTransaction>> BuilderTask<TYPES> for RandomBuilderTask<TYPES>
where <TYPES as NodeType>::InstanceState: Default,