Struct sc_consensus::import_queue::buffered_link::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: &mut dyn Link<B>
)

Send action for the synchronization to perform.

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

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

pub fn close(&mut self)

Close the channel.