Struct GenericAioContext

Source

pub struct GenericAioContext<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default>where
    A::LinkOps: LinkedListOps + Default,
{ /* private fields */ }

Expand description

Represents running AIO context. Must be kept while AIO is in use. In order to close it, close should be called. It will wait until all related futures are finished. Otherwise, if it just dropped, the termination will be triggered, but some running futures will continue running until they receive the data.

Struct GenericAioContextCopy item path

Implementations§

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> GenericAioContext<M, A, L>where A::LinkOps: LinkedListOps + Default,

pub fn available_slots(&self) -> Option<usize>

pub async fn close(self)

Trait Implementations§

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> Debug for GenericAioContext<M, A, L>where A::LinkOps: LinkedListOps + Default,

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

Auto Trait Implementations§

impl<M, A, L> Freeze for GenericAioContext<M, A, L>where <A as Adapter>::LinkOps: Sized,

impl<M, A, L> !RefUnwindSafe for GenericAioContext<M, A, L>

impl<M, A, L> Send for GenericAioContext<M, A, L>where <A as Adapter>::LinkOps: Sized, M: Sync + Send, A: Send, L: Send,

impl<M, A, L> Sync for GenericAioContext<M, A, L>where <A as Adapter>::LinkOps: Sized, M: Sync + Send, A: Send, L: Send,

impl<M, A, L> Unpin for GenericAioContext<M, A, L>where <A as Adapter>::LinkOps: Sized,

impl<M, A, L> !UnwindSafe for GenericAioContext<M, A, L>

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

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

fn into(self) -> U

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

type Error = Infallible

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

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

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

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

Struct GenericAioContext

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> GenericAioContext<M, A, L>
where A::LinkOps: LinkedListOps + Default,

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> Debug for GenericAioContext<M, A, L>
where A::LinkOps: LinkedListOps + Default,

impl<M, A, L> Freeze for GenericAioContext<M, A, L>
where <A as Adapter>::LinkOps: Sized,

impl<M, A, L> Send for GenericAioContext<M, A, L>
where <A as Adapter>::LinkOps: Sized, M: Sync + Send, A: Send, L: Send,

impl<M, A, L> Sync for GenericAioContext<M, A, L>
where <A as Adapter>::LinkOps: Sized, M: Sync + Send, A: Send, L: Send,

impl<M, A, L> Unpin for GenericAioContext<M, A, L>
where <A as Adapter>::LinkOps: Sized,

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

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

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

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

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

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