i2o2

Struct I2o2Scheduler

Source 
pub struct I2o2Scheduler<G = DynamicGuard> { /* private fields */ }
Expand description

The I2o2Scheduler runs an io_uring ring in the current thread and submits IO events from the handle into the ring.

Communication between the handles and the scheduler can be done both synchronously and asynchronously.

Implementations§

Source§

impl<G> I2o2Scheduler<G>

Source

pub fn run(self) -> Result<()>

Run the scheduler in the current thread until it is shut down.

This will wait for all remaining tasks to complete.

Auto Trait Implementations§

§

impl<G> Freeze for I2o2Scheduler<G>

§

impl<G = Box<dyn Any + Send>> !RefUnwindSafe for I2o2Scheduler<G>

§

impl<G = Box<dyn Any + Send>> !Send for I2o2Scheduler<G>

§

impl<G = Box<dyn Any + Send>> !Sync for I2o2Scheduler<G>

§

impl<G> Unpin for I2o2Scheduler<G>
where G: Unpin,

§

impl<G = Box<dyn Any + Send>> !UnwindSafe for I2o2Scheduler<G>

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> 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> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
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>,

Source§

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>,

Source§

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.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more