Struct BufferedLinkReceiver

pub struct BufferedLinkReceiver<B: BlockT> { /* private fields */ }

See buffered_link.

Implementations

impl<B: BlockT> BufferedLinkReceiver<B>

pub fn send_actions(&mut self, msg: BlockImportWorkerMsg<B>, link: &dyn Link<B>)

Send action for the synchronization to perform.

pub fn poll_actions( &mut self, cx: &mut Context<'_>, link: &dyn Link<B>, ) -> Result<(), ()>

Polls for the buffered link actions. Any enqueued action will be propagated to the link passed as parameter.

This method should behave in a way similar to Future::poll. It can register the current task and notify later when more actions are ready to be polled. To continue the comparison, it is as if this method always returned Poll::Pending.

Returns an error if the corresponding BufferedLinkSender has been closed.

pub async fn next_action(&mut self, link: &dyn Link<B>) -> Result<(), ()>

Poll next element from import queue and send the corresponding action command over the link.

pub fn close(&mut self) -> bool

Close the channel.