Struct aldrin_core::channel::Bounded

source · 
pub struct Bounded { /* private fields */ }
Expand description

A bounded channels-based transport for connecting a broker and a client in the same process.

Bounded transports have an internal fifo for receiving Messages. If this runs full, backpressure will be applied to the sender.

Trait Implementations§

source§

impl AsyncTransport for Bounded

§

type Error = Disconnected

Error type when sending or receiving messages.
source§

fn receive_poll( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<Message, Disconnected>>

Attempts to receive the next message.
source§

fn send_poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Disconnected>>

Prepares the transport for sending a message. Read more
source§

fn send_start(self: Pin<&mut Self>, msg: Message) -> Result<(), Disconnected>

Begins sending a message. Read more
source§

fn send_poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_> ) -> Poll<Result<(), Disconnected>>

Attempts to flush the transport. Read more
source§

impl Debug for Bounded

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> AsyncTransportExt for T
where T: AsyncTransport,

source§

fn receive(&mut self) -> Receive<'_, Self> ⓘ
where Self: Unpin,

source§

fn send(&mut self, msg: Message) -> Send<'_, Self> ⓘ
where Self: Unpin,

source§

fn flush(&mut self) -> Flush<'_, Self> ⓘ
where Self: Unpin,

source§

fn send_and_flush(&mut self, msg: Message) -> SendFlush<'_, Self> ⓘ
where Self: Unpin,

source§

fn receive_poll_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Message, Self::Error>>
where Self: Unpin,

source§

fn send_poll_ready_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>
where Self: Unpin,

source§

fn send_start_unpin(&mut self, msg: Message) -> Result<(), Self::Error>
where Self: Unpin,

source§

fn send_poll_flush_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>
where Self: Unpin,

source§

fn map_err<F, E>(self, f: F) -> MapError<Self, F>
where Self: Sized, F: FnMut(Self::Error) -> E,

source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.