/dports/net/py-trio/trio-0.19.0/trio/_core/tests/ |
H A D | test_io.py | 52 wait_writable_options = [trio.lowlevel.wait_writable] 87 await wait_writable(a) 118 await wait_writable(a) 161 async def test_double_write(socketpair, wait_writable): argument 167 nursery.start_soon(wait_writable, a) 170 await wait_writable(a) 188 await wait_writable(a) 209 await wait_writable(sock) 249 await wait_writable(sock) 337 nursery.start_soon(_core.wait_writable, a1) [all …]
|
/dports/lang/ruby26/ruby-2.6.9/test/io/wait/ |
H A D | test_io_wait.rb | 115 assert_equal @w, @w.wait_writable 119 assert_equal @w, @w.wait_writable(0.01) 121 assert_nil @w.wait_writable(0.01) 123 assert_equal @w, @w.wait_writable(0.01) 129 assert_equal @w, @w.wait_writable 134 assert_raise(IOError) { @w.wait_writable }
|
H A D | test_io_wait_uncommon.rb | 15 assert_equal tty, tty.wait_writable(1), 'portability test' 35 assert_same wr, wr.wait_writable(0)
|
/dports/net/py-trio/trio-0.19.0/trio/_core/ |
H A D | _generated_io_epoll.py | 19 async def wait_writable(fd): function 22 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(fd)
|
H A D | _generated_io_kqueue.py | 43 async def wait_writable(fd): function 46 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(fd)
|
H A D | _generated_io_windows.py | 19 async def wait_writable(sock): function 22 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(sock)
|
H A D | __init__.py | 50 wait_writable,
|
H A D | _io_epoll.py | 302 async def wait_writable(self, fd): member in EpollIOManager
|
/dports/net/py-trio/trio-0.19.0/trio/ |
H A D | _socket.py | 480 async def wait_writable(self): member in _SocketType 481 await _core.wait_writable(self._sock) 672 await _core.wait_writable(self._sock) 732 send = _make_simple_sock_method_wrapper("send", _core.wait_writable) 746 _stdlib_socket.socket.sendto, args, {}, _core.wait_writable 771 _stdlib_socket.socket.sendmsg, args, {}, _core.wait_writable
|
H A D | _unix_pipes.py | 135 await trio.lowlevel.wait_writable(self._fd_holder.fd) 149 await trio.lowlevel.wait_writable(self._fd_holder.fd)
|
H A D | lowlevel.py | 43 wait_writable,
|
H A D | _highlevel_socket.py | 118 await self.socket.wait_writable()
|
/dports/lang/ruby26/ruby-2.6.9/lib/net/ |
H A D | protocol.rb | 46 when :wait_writable; s.to_io.wait_writable(timeout) 222 (io = @io.to_io).wait_writable(@read_timeout) or raise Net::ReadTimeout.new(io) 296 (io = @io.to_io).wait_writable(@write_timeout) or raise Net::WriteTimeout.new(io)
|
/dports/lang/ruby26/ruby-2.6.9/test/net/protocol/ |
H A D | test_protocol.rb | 36 def mockio.wait_writable(sec); sleep sec; false; end singletonMethod
|
/dports/multimedia/scte35dump/scte35dump-0.1.6/cargo-crates/mio-0.6.19/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/mio-0.6.21/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/editors/xi-term/xi-term-d264767/cargo-crates/mio-0.6.19/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/mio-0.6.21/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/editors/xi-core/xi-editor-0.3.0/rust/cargo-crates/mio-0.6.19/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/mio-0.6.19/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/mio-0.6.21/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/mio/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/mio-0.6.19/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { in write_error() localVariable 642 wait_writable(); in write_error() 652 wait_writable() in write_error()
|
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/mio-0.6.21/test/ |
H A D | test_tcp.rs | 629 let mut wait_writable = || { 642 wait_writable(); 652 wait_writable()
|
/dports/lang/ruby26/ruby-2.6.9/lib/ |
H A D | un.rb | 249 def wait_writable method
|