Searched refs:resume_reading (Results 1 – 19 of 19) sorted by relevance
191 def resume_reading(self): member in _ProactorReadPipeTransport589 resume_reading = transp.is_reading()597 if resume_reading:598 transp.resume_reading()
339 def resume_reading(self): member in _SSLProtocolTransport345 self._ssl_protocol._transport.resume_reading()684 self._transport.resume_reading()
59 def resume_reading(self): member in ReadTransport
535 resume_reading = transp.is_reading()543 if resume_reading:544 transp.resume_reading()755 def resume_reading(self): member in _SelectorSocketTransport
417 self._transport.resume_reading()469 self._transport.resume_reading()
237 self._transport.resume_reading()1131 resume_cb = self.call_soon(transport.resume_reading)
497 def resume_reading(self): member in _UnixReadPipeTransport
44 self.assertRaises(NotImplementedError, transport.resume_reading)
372 tr.resume_reading()373 tr.resume_reading()382 tr.resume_reading()711 tr.resume_reading()712 tr.resume_reading()
266 transport.resume_reading = mock.Mock()292 self.assertTrue(transport.resume_reading.called)
95 transport.resume_reading()96 transport.resume_reading()934 tr.resume_reading()935 tr.resume_reading()
725 tr.resume_reading()
321 * - :meth:`transport.resume_reading() <ReadTransport.resume_reading>`
246 method until :meth:`resume_reading` is called.252 .. method:: ReadTransport.resume_reading()
75 pause_reading()/resume_reading() when using the ProactorEventLoop.
317 Fix race condition with `ReadTransport.resume_reading` in Windows proactor
357 asyncio.transport.resume_reading() and pause_reading() are now idempotent.
251 Fix race condition with `ReadTransport.resume_reading` in Windows proactor
749 :meth:`ReadTransport.resume_reading() <asyncio.ReadTransport.resume_reading>`