Struct ChannelInputSource 

pub struct ChannelInputSource { /* private fields */ }

Input source backed by an async channel.

This is the default source used internally. The consumer sends input through a channel that this source reads from.

Implementations

impl ChannelInputSource

pub fn new(rx: Receiver<ControllerInputPayload>) -> Self

Create a new channel-backed input source.

pub fn channel(buffer: usize) -> (Sender<ControllerInputPayload>, Self)

Create a channel pair for input.

Returns (sender, source) where sender is used by the consumer to send input and source is passed to the engine.

Trait Implementations

impl InputSource for ChannelInputSource

fn recv( &mut self, ) -> Pin<Box<dyn Future<Output = Option<ControllerInputPayload>> + Send + '_>>

Receive the next input from the consumer.