Struct PollRegistry

Source
pub struct PollRegistry { /* private fields */ }

Implementations§

Source§

impl PollRegistry

Source

pub fn try_clone(&self) -> IoResult<Self>

Source§

impl PollRegistry

Source

pub fn register<S: Source + ?Sized>( &self, handle: &mut S, interest: Interest, wakers: SourceWaker, ) -> IoResult<Token>

Registers a [mio::Evented] handle in the wrapped mio::Poll, along with a std::task::Waker, allowing an async wrapper of the given handle to be woken. This abstracts the mio::Poll <-> mio::Token relationship to allow a reactor to wake wrapped handlers.

§Panics

This function may panic if there are more than usize concurrent handlers registered. This is highly unlikely in most practical cases, as process sharding is essentially guaranteed to be needed before that number of handlers is reached.

Trait Implementations§

Source§

impl Sync for PollRegistry

§Safety

The factor that prevents it from being interpreted as safe is the Sender for Token values. The Registry only has a copy for the sake of making copies for Tokens. As long as the Registry doesn’t use token_drop_box itself, this is safe.

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