Struct Proxy

pub struct Proxy<T: 'static> { /* private fields */ }

An event loop proxy with backpressure that implements Sink.

Implementations

impl<T: 'static> Proxy<T>

pub fn new(raw: EventLoopProxy<Action<T>>) -> (Self, impl Future<Output = ()>)

Creates a new Proxy from an EventLoopProxy.

pub fn send(&mut self, value: T)

where T: Debug,

Sends a value to the event loop.

Note: This skips the backpressure mechanism with an unbounded channel. Use sparingly!

pub fn send_action(&mut self, action: Action<T>)

where T: Debug,

Sends an action to the event loop.

Note: This skips the backpressure mechanism with an unbounded channel. Use sparingly!

pub fn free_slots(&mut self, amount: usize)

Frees an amount of slots for additional messages to be queued in this Proxy.

Trait Implementations

impl<T: 'static> Clone for Proxy<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + 'static> Debug for Proxy<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: 'static> Sink<Action<T>> for Proxy<T>

type Error = SendError

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, action: Action<T>, ) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.