Trait FeedSource 

pub trait FeedSource {
    type Item;

    // Required methods
    fn wait(&mut self) -> impl Future<Output = Option<Self::Item>>;
    fn poll_now(&mut self) -> Option<Self::Item>;
}

Something a control loop waits on and then drains: one awaited receive for the select! arm, and a non-blocking receive for the batch that follows.

Required Associated Types

type Item

Required Methods

fn wait(&mut self) -> impl Future<Output = Option<Self::Item>>

Cancel-safe: a wait that loses the race must not drop a message.

fn poll_now(&mut self) -> Option<Self::Item>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<T: Clone> FeedSource for Receiver<T>

type Item = T

async fn wait(&mut self) -> Option<T>

fn poll_now(&mut self) -> Option<T>

impl<T> FeedSource for Receiver<T>

type Item = T

fn wait(&mut self) -> impl Future<Output = Option<T>>

fn poll_now(&mut self) -> Option<T>

impl<T> FeedSource for UnboundedReceiver<T>

type Item = T

fn wait(&mut self) -> impl Future<Output = Option<T>>

fn poll_now(&mut self) -> Option<T>

Implementors

impl FeedSource for CredentialSyncCoordinator

type Item = CredentialSyncResult

impl FeedSource for RecoveryCoordinator

type Item = RecoveryResult

impl FeedSource for SessionManagerUpdates

type Item = SessionManagerUpdate