Lines Matching refs:waiter
306 for waiter in waiters:
307 if not waiter.done():
308 waiter.set_result(waiter)
382 waiter = self._loop.create_future()
383 self._waiters.append(waiter)
384 await waiter
468 def _make_socket_transport(self, sock, protocol, waiter=None, *,
474 self, rawsock, protocol, sslcontext, waiter=None,
484 address=None, waiter=None, extra=None):
488 def _make_read_pipe_transport(self, pipe, protocol, waiter=None,
493 def _make_write_pipe_transport(self, pipe, protocol, waiter=None,
1133 waiter = self.create_future()
1137 sock, protocol, sslcontext, waiter,
1142 transport = self._make_socket_transport(sock, protocol, waiter)
1145 await waiter
1250 waiter = self.create_future()
1252 self, protocol, sslcontext, waiter,
1267 await waiter
1389 waiter = self.create_future()
1391 sock, protocol, r_addr, waiter)
1403 await waiter
1588 waiter = self.create_future()
1589 transport = self._make_read_pipe_transport(pipe, protocol, waiter)
1592 await waiter
1604 waiter = self.create_future()
1605 transport = self._make_write_pipe_transport(pipe, protocol, waiter)
1608 await waiter