Lines Matching refs:interest

31 `Registration` is updated to support waiting for an arbitrary interest set with
32 `&self`. This supports concurrent waiters with a different readiness interest.
44     /// `interest` must be a super set of **all** interest sets specified in
45     /// the other methods. This is the interest set passed to `mio`.
46     pub fn new<T>(io: &T, interest: mio::Ready) -> io::Result<Registration>
49     /// Awaits for any readiness event included in `interest`. Returns a
51     async fn readiness(&self, interest: mio::Ready) -> io::Result<ReadyEvent>;
57 A new registration is created for a `T: mio::Evented` and a `interest`. This
67 overlaps with `interest`. If it does, then the `readiness()` immediately
77         let event = self.readiness(interest).await?;
93 entry in the linked list includes the `interest` set passed to `readiness()`.
129     interest: mio::Ready,
137 updated and the waiter list is iterated. All waiters with `interest` that
138 overlap the received readiness event are notified. Any waiter with an `interest`
141 ## Cancel interest on drop
159         let event = self.readiness(interest).await?;
212 not possible to cancel interest in the readiness events.
216 used to store the waker. Specific `interest` is not tracked for `AsyncRead` and
217 `AsyncWrite` implementations. It is assumed that only events of interest are: