Struct Mpsc

pub struct Mpsc { /* private fields */ }

A paired mpsc transport.

Implementations

impl Mpsc

pub fn new() -> (Self, Self)

Creates two mpscs which can communicate with each other.

Trait Implementations

impl NonBlockingTransport for Mpsc

fn send_immediately( future_state: &mut Self::SendFutureState, shared: &Self::Shared, ) -> Result<(), Option<Self::Error>>

Completes a SendFutureState with the shared part of the transport without blocking.

impl Transport for Mpsc

type Error = Error

The error type for the transport.

type Shared = Shared

The shared part of the transport. It is provided by shared reference while sending and receiving. For an MPSC, this would contain a sender.

type SendBuffer = Vec<WireU64>

The buffer type for sending.

type SendFutureState = SendFutureState

The future state for send operations.

type Exclusive = Exclusive

The exclusive part of the transport. It is provided by mutable reference only while receiving. For an MPSC, this would contain a receiver.

type RecvFutureState = RecvFutureState

The future state for receive operations.

type RecvBuffer = RecvBuffer

The buffer type for receivers.

fn split(self) -> (Self::Shared, Self::Exclusive)

Splits the transport into shared and exclusive pieces.

fn acquire(_: &Self::Shared) -> Self::SendBuffer

Acquires an empty send buffer for the transport.

fn begin_send( _: &Self::Shared, buffer: Self::SendBuffer, ) -> Self::SendFutureState

Begins sending a SendBuffer over this transport.

fn poll_send( future_state: Pin<&mut SendFutureState>, _: &mut Context<'_>, shared: &Self::Shared, ) -> Poll<Result<(), Option<Error>>>

Polls a SendFutureState for completion with the shared part of the transport.

fn begin_recv( _: &Self::Shared, _: &mut Self::Exclusive, ) -> Self::RecvFutureState

Begins receiving a RecvBuffer over this transport.

fn poll_recv( _: Pin<&mut Self::RecvFutureState>, cx: &mut Context<'_>, shared: &Self::Shared, exclusive: &mut Self::Exclusive, ) -> Poll<Result<Self::RecvBuffer, Option<Self::Error>>>

Polls a RecvFutureState for completion with a receiver.