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 Transport for Mpsc

type Error = Error

The error type for the transport.

type Sender = Sender

The sender half of the transport. Dropping all of the senders for a transport should close the transport.

type SendBuffer = Vec<WireU64>

The buffer type for senders.

type SendFutureState = SendFutureState

The future state for send operations.

type Receiver = Receiver

The receiver half of the transport.

type RecvFutureState = RecvFutureState

The future state for receive operations.

type RecvBuffer = RecvBuffer

The buffer type for receivers.

fn split(self) -> (Self::Sender, Self::Receiver)

Splits the transport into a sender and receiver.

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

Acquires an empty send buffer for the transport.

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

Begins sending a SendBuffer over this transport.

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

Polls a SendFutureState for completion with a sender.

fn close(sender: &Self::Sender)

Closes the transport.

fn begin_recv(_: &mut Self::Receiver) -> Self::RecvFutureState

Begins receiving a RecvBuffer over this transport.

fn poll_recv( _: Pin<&mut Self::RecvFutureState>, cx: &mut Context<'_>, receiver: &mut Self::Receiver, ) -> Poll<Result<Option<Self::RecvBuffer>, Self::Error>>

Polls a RecvFutureState for completion with a receiver.