Struct Mpsc

pub struct Mpsc { /* private fields */ }

A paired mpsc transport.

Implementations

impl Mpsc

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

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.

type SendBuffer = Vec<u64_le>

The buffer type for senders.

type Encoder<'b> = &'b mut Vec<u64_le>

The encoder for send buffers.

type SendFuture<'s> = SendFuture<'s>

The future type for send operations.

type Receiver = Receiver

The receiver half of the transport.

type RecvFuture<'r> = RecvFuture<'r>

The future type for receive operations.

type RecvBuffer = RecvBuffer

The buffer type for receivers.

type Decoder<'b> = &'b mut RecvBuffer

The decoder for receive buffers.

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 encoder(buffer: &mut Self::SendBuffer) -> Self::Encoder<'_>

Gets the encoder for a buffer.

fn send(sender: &Self::Sender, buffer: Self::SendBuffer) -> Self::SendFuture<'_>

Sends an encoded message over the transport.

fn recv(receiver: &mut Self::Receiver) -> Self::RecvFuture<'_>

Receives an encoded message over the transport.

fn decoder(buffer: &mut Self::RecvBuffer) -> Self::Decoder<'_>

Gets the decoder for a buffer.