Struct Inplace

pub struct Inplace<T> { /* private fields */ }

A futures-aware bounded(1) channel.

Implementations

impl<T> Inplace<T>

pub fn send(&self, val: T) -> Result<(), T>

Set a successful result.

If the value is successfully enqueued for the remote end to receive, then Ok(()) is returned. If previose value is not consumed then Err is returned with the value provided.

pub async fn recv(&self) -> T

Wait until the oneshot is ready and return value

pub fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<T>

Polls the oneshot to determine if value is ready

Trait Implementations

impl<T> Debug for Inplace<T>

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

Formats the value using the given formatter.

impl<T> Unpin for Inplace<T>