danog/dns
1
0
Fork 0
mirror of https://github.com/danog/dns.git synced 2024-11-30 04:29:06 +01:00
Code Issues Projects Releases Wiki Activity

Use anonymous class

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-06-22 18:46:08 -05:00
parent ed1ea12067
commit ba8a8423eb
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
lib/DefaultResolver.php
View File

@ -361,15 +361,27 @@ class DefaultResolver implements Resolver {
\stream_set_blocking($socket, false);
$id = (int) $socket;
$server = new \StdClass;
$server = new class {
use Amp\Struct;
public $id;
public $uri;
public $server;
public $socket;
public $buffer = "";
public $length = INF;
public $pendingRequests = [];
public $watcherId;
public $connect;
};
$server->id = $id;
$server->uri = $uri;
$server->socket = $socket;
$server->buffer = "";
$server->length = INF;
$server->pendingRequests = [];
$server->watcherId = Loop::onReadable($socket, $this->callableFromInstanceMethod("onReadable"));
Loop::disable($server->watcherId);
$this->serverIdMap[$id] = $server;
$this->serverUriMap[$uri] = $server;
@ -379,7 +391,7 @@ class DefaultResolver implements Resolver {
$watcher = Loop::onWritable($server->socket, static function ($watcher) use ($server, $deferred, &$timer) {
Loop::cancel($watcher);
Loop::cancel($timer);
unset($server->connect);
$server->connect = null;
$deferred->resolve();
});
// TODO: Respect timeout