Struct DriverChannel

pub struct DriverChannel<D = CurrentDispatcher> { /* private fields */ }

A fidl-compatible driver channel that also holds a reference to the dispatcher. Defaults to using CurrentDispatcher.

Implementations

impl<D> DriverChannel<D>

pub fn new_with_dispatcher(dispatcher: D, channel: Channel<[Chunk]>) -> Self

Create a new driver fidl channel that will perform its operations on the given dispatcher handle.

impl DriverChannel<CurrentDispatcher>

pub fn new(channel: Channel<[Chunk]>) -> Self

Create a new driver fidl channel that will perform its operations on the CurrentDispatcher.

Trait Implementations

impl<D: OnDispatcher> Transport for DriverChannel<D>

type Error = Status

The error type for the transport.

type Sender = DriverSender<D>

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

type SendBuffer = SendBuffer

The buffer type for senders.

type SendFutureState = SendBuffer

The future state for send operations.

type Receiver = DriverReceiver<D>

The receiver half of the transport.

type RecvFutureState = DriverRecvState

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(_sender: &Self::Sender) -> Self::SendBuffer

Acquires an empty send buffer for the transport.

fn close(sender: &Self::Sender)

Closes the transport.

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

Begins sending a SendBuffer over this transport.

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

Polls a SendFutureState for completion with a sender.

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

Begins receiving a RecvBuffer over this transport.

fn poll_recv( future: 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.