HomeSort by relevance Sort by last modified time
    Searched refs:_proactor (Results 1 - 4 of 4) sorted by null

  /external/python/cpython3/Lib/test/test_asyncio/
test_proactor_events.py 31 self.loop._proactor = self.proactor
52 self.loop._proactor.recv.assert_called_with(self.sock, 4096)
63 self.loop._proactor.recv.assert_called_with(self.sock, 4096)
76 self.assertFalse(self.loop._proactor.recv.called)
81 err = self.loop._proactor.recv.side_effect = ConnectionAbortedError()
91 self.loop._proactor.recv.side_effect = ConnectionAbortedError()
100 self.loop._proactor.recv.side_effect = ConnectionAbortedError()
108 err = self.loop._proactor.recv.side_effect = ConnectionResetError()
119 err = self.loop._proactor.recv.side_effect = (OSError())
152 self.loop._proactor.send.assert_called_with(self.sock, b'data'
    [all...]
test_windows_events.py 100 coro = self.loop._proactor.connect_pipe('pipe_address')
114 fut = self.loop._proactor.wait_for_handle(event, 0.5)
127 fut = self.loop._proactor.wait_for_handle(event, 10)
146 fut = self.loop._proactor.wait_for_handle(event, 10)
156 fut = self.loop._proactor.wait_for_handle(event)
  /external/python/cpython3/Lib/asyncio/
proactor_events.py 202 self._read_fut = self._loop._proactor.recv(self._sock, 4096)
290 self._write_fut = self._loop._proactor.send(self._sock, data)
316 self._read_fut = self._loop._proactor.recv(self._sock, 16)
384 self._proactor = proactor
436 self._proactor.close()
437 self._proactor = None
444 return self._proactor.recv(sock, n)
447 return self._proactor.send(sock, data)
450 return self._proactor.connect(sock, address)
453 return self._proactor.accept(sock
    [all...]
windows_events.py 188 self._proactor = proactor
206 self._proactor._unregister(self._ov)
207 self._proactor = None
233 self._event_fut = self._proactor._wait_cancel(self._event,
316 f = self._proactor.connect_pipe(address)
348 f = self._proactor.accept_pipe(pipe)
768 f = self._loop._proactor.wait_for_handle(int(self._proc._handle))

Completed in 447 milliseconds