Lines Matching refs:in_notify
41 fn in_notify<R>(&mut self, cx: &mut Context<'_>, f: impl FnOnce(&mut T) -> R) -> R { in in_notify() method
164 poll_01_to_03(self.in_notify(cx, Future01::poll)) in poll()
175 match self.in_notify(cx, Stream01::poll)? { in poll_next()
208 fn in_notify<R>( in in_notify() method
244 match self.in_notify(cx, Stream01::poll)? { in poll_next()
273 Some(item) => match self.in_notify(cx, |f| f.start_send(item))? { in poll_ready()
289 match self.in_notify(cx, |f| match item { in poll_flush()
313 let result = self.in_notify(cx, |f| { in poll_close()
453 poll_01_to_03(self.in_notify(cx, |x| x.poll_read(buf))) in poll_read()
461 poll_01_to_03(self.in_notify(cx, |x| x.poll_write(buf))) in poll_write()
467 poll_01_to_03(self.in_notify(cx, AsyncWrite01::poll_flush)) in poll_flush()
473 poll_01_to_03(self.in_notify(cx, AsyncWrite01::shutdown)) in poll_close()