Home
last modified time | relevance | path

Searched refs:wait_writable (Results 1 – 25 of 45) sorted by relevance

12

/dports/net/py-trio/trio-0.19.0/trio/_core/tests/
H A Dtest_io.py52 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 Dtest_io_wait.rb115 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 Dtest_io_wait_uncommon.rb15 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.py19 async def wait_writable(fd): function
22 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(fd)
H A D_generated_io_kqueue.py43 async def wait_writable(fd): function
46 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(fd)
H A D_generated_io_windows.py19 async def wait_writable(sock): function
22 return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_writable(sock)
H A D__init__.py50 wait_writable,
H A D_io_epoll.py302 async def wait_writable(self, fd): member in EpollIOManager
/dports/net/py-trio/trio-0.19.0/trio/
H A D_socket.py480 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.py135 await trio.lowlevel.wait_writable(self._fd_holder.fd)
149 await trio.lowlevel.wait_writable(self._fd_holder.fd)
H A Dlowlevel.py43 wait_writable,
H A D_highlevel_socket.py118 await self.socket.wait_writable()
/dports/lang/ruby26/ruby-2.6.9/lib/net/
H A Dprotocol.rb46 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 Dtest_protocol.rb36 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 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 Dtest_tcp.rs629 let mut wait_writable = || {
642 wait_writable();
652 wait_writable()
/dports/lang/ruby26/ruby-2.6.9/lib/
H A Dun.rb249 def wait_writable method

12