Struct UringB

pub struct UringB<A, B, Ext = ()>(/* private fields */);

Implementations

impl<A, B, Ext> UringB<A, B, Ext>

pub fn into_raw(self) -> RawUring<A, B, Ext>

pub fn dispose_raw(self) -> Result<RawUring<A, B, Ext>, DisposeError>

Drops this Uring and all enqueued entries.

It does nothing and returns an error if self is still connected. Otherwise, the returned RawUring is safe to deallocate without synchronization.

pub unsafe fn from_raw(uring: RawUring<A, B, Ext>) -> Self

Safety

The specified RawUring must be a valid value returned from into_raw.

Trait Implementations

impl<A, B, Ext> Drop for UringB<A, B, Ext>

fn drop(&mut self)

Executes the destructor for this type.

impl<A, B, Ext> Uring for UringB<A, B, Ext>

type A = B

type B = A

type Ext = Ext

fn header(&self) -> &Header<Ext>

fn sender(&self) -> Queue<'_, Self::A>

fn receiver(&self) -> Queue<'_, Self::B>

fn ext(&self) -> &Self::Ext

where Self::Ext: Sync,

fn is_connected(&self) -> bool

Returns true if the remote Uring is not dropped.

fn send(&mut self, val: Self::A) -> Result<(), Self::A>

fn send_bulk<I>(&mut self, vals: I) -> usize

where I: Iterator<Item = Self::A>,

fn recv(&mut self) -> Option<Self::B>

fn recv_bulk(&mut self) -> Drain<'_, Self::B>

impl<A: Send, B: Send, Ext: Send> Send for UringB<A, B, Ext>