| /dports/devel/poco/poco-1.10.1-all/Net/include/Poco/Net/ |
| H A D | SocketConnector.h | 115 …ocket, Poco::Observer<SocketConnector, WritableNotification>(*this, &SocketConnector::onWritable)); in registerConnector()
130 …ocket, Poco::Observer<SocketConnector, WritableNotification>(*this, &SocketConnector::onWritable)); in unregisterConnector()
150 void onWritable(WritableNotification* pNotification) in onWritable() function
|
| /dports/devel/poco/poco-1.10.1-all/Foundation/testsuite/src/ |
| H A D | FIFOBufferStreamTest.cpp | 98 iostr.writable += delegate(this, &FIFOBufferStreamTest::onWritable); in testNotify()
161 iostr.writable -= delegate(this, &FIFOBufferStreamTest::onWritable); in testNotify()
172 void FIFOBufferStreamTest::onWritable(bool& b) in onWritable() function in FIFOBufferStreamTest
|
| H A D | FIFOBufferStreamTest.h | 38 void onWritable(bool& b);
|
| H A D | CoreTest.h | 47 void onWritable(bool& b);
|
| H A D | CoreTest.cpp | 332 f.writable += delegate(this, &CoreTest::onWritable); in testFIFOBufferEOFAndError()
438 f.writable += delegate(this, &CoreTest::onWritable); in testFIFOBufferChar()
1128 void CoreTest::onWritable(bool& b) in onWritable() function in CoreTest
|
| /dports/mail/nextcloud-mail/mail/vendor/amphp/amp/lib/Loop/ |
| H A D | Driver.php | 330 public function onWritable($stream, callable $callback, $data = null): string function in Amp\\Loop\\Driver
686 $defer = $delay = $repeat = $onReadable = $onWritable = $onSignal = [
697 $array = &$onWritable;
737 "on_writable" => $onWritable,
|
| H A D | TracingDriver.php | 81 public function onWritable($stream, callable $callback, $data = null): string function in Amp\\Loop\\TracingDriver
83 $id = $this->driver->onWritable($stream, $callback, $data);
|
| /dports/mail/nextcloud-mail/mail/vendor/amphp/amp/lib/ |
| H A D | Loop.php | 216 public static function onWritable($stream, callable $callback, $data = null): string function in Amp\\Loop
218 return self::$driver->onWritable($stream, $callback, $data);
|
| /dports/www/uwebsockets/uWebSockets-20.8.0/src/ |
| H A D | HttpResponse.h | 78 httpResponseData->onWritable = nullptr; in markDone()
462 HttpResponse *onWritable(MoveOnlyFunction<bool(uintmax_t)> &&handler) { in onWritable() function
465 httpResponseData->onWritable = std::move(handler); in onWritable()
|
| H A D | HttpResponseData.h | 46 MoveOnlyFunction<bool(uintmax_t)> onWritable; member
|
| H A D | HttpContext.h | 303 if (httpResponseData->onWritable) { in init()
309 bool success = httpResponseData->onWritable(httpResponseData->offset); in init()
|
| /dports/devel/poco/poco-1.10.1-all/Net/testsuite/src/ |
| H A D | SocketTest.h | 52 void onWritable(bool& b);
|
| H A D | SocketReactorTest.cpp | 89 _ow(*this, &ClientServiceHandler::onWritable), in ClientServiceHandler()
141 void onWritable(WritableNotification* pNf) in onWritable() function in __anon79dc36eb0111::ClientServiceHandler
145 …t, Observer<ClientServiceHandler, WritableNotification>(*this, &ClientServiceHandler::onWritable)); in onWritable()
|
| H A D | SocketTest.cpp | 122 f.writable += delegate(this, &SocketTest::onWritable); in testFIFOBuffer()
160 f.writable -= delegate(this, &SocketTest::onWritable); in testFIFOBuffer()
536 void SocketTest::onWritable(bool& b) in onWritable() function in SocketTest
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/ |
| H A D | TLSConnection.actor.cpp | 82 wait( r == ITLSSession::WANT_WRITE ? self->conn->onWritable() : self->conn->onReadable() ); in handshake()
102 Future<Void> TLSConnection::onWritable() { in onWritable() function in TLSConnection
107 write_wants == ITLSSession::WANT_WRITE ? conn->onWritable() : in onWritable()
116 read_wants == ITLSSession::WANT_WRITE ? conn->onWritable() : in onReadable()
|
| H A D | TLSConnection.h | 52 virtual Future<Void> onWritable();
|
| H A D | FlowTransport.actor.cpp | 417 wait( conn->onWritable() ); in connectionWriter()
|
| /dports/net-mgmt/icingaweb2-module-reactbundle/icingaweb2-module-reactbundle-0.9.0/vendor/react/datagram/src/ |
| H A D | Buffer.php | 38 public function onWritable() function in React\\Datagram\\Buffer
|
| /dports/audio/ampache/ampache-php74-5.0.0/vendor/react/datagram/src/ |
| H A D | Buffer.php | 38 public function onWritable() function in React\\Datagram\\Buffer
|
| /dports/www/uwebsockets/uWebSockets-20.8.0/examples/helpers/ |
| H A D | AsyncFileStreamer.h | 72 res->onWritable([res, asyncFileReader](int offset) { in streamFile()
|
| /dports/mail/nextcloud-mail/mail/vendor/amphp/byte-stream/lib/ |
| H A D | ResourceOutputStream.php | 60 …$this->watcher = Loop::onWritable($stream, static function ($watcher, $stream) use ($writes, &$chu…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/flow/ |
| H A D | network.h | 297 virtual Future<Void> onWritable() = 0;
|
| H A D | Net2.actor.cpp | 310 virtual Future<Void> onWritable() { in onWritable() function in N2::Connection
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbclient/ |
| H A D | HTTP.actor.cpp | 355 wait(conn->onWritable()); in doRequest()
|
| /dports/www/uwebsockets/uWebSockets-20.8.0/misc/ |
| H A D | READMORE.md | 86 …s.tryEnd to stream huge data part by part. Use in combination with res.onWritable and res.onAborte…
168 …value of ws.send before sending any more data. WebSockets do not have .onWritable, but instead mak…
|