Avoid problems with HTTP
This commit is contained in:
parent
0fcf83d9ad
commit
f6573be332
@ -427,6 +427,17 @@ class Connection extends Session
|
|||||||
$this->writer->resume();
|
$this->writer->resume();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
/**
|
||||||
|
* Resume HttpWaiter
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function pingHttpWaiter()
|
||||||
|
{
|
||||||
|
if (isset($this->waiter)) {
|
||||||
|
$this->waiter->resume();
|
||||||
|
}
|
||||||
|
}
|
||||||
/**
|
/**
|
||||||
* Connect main instance.
|
* Connect main instance.
|
||||||
*
|
*
|
||||||
|
@ -130,7 +130,7 @@ class ReadLoop extends SignalLoop
|
|||||||
Loop::defer([$connection, 'handle_messages']);
|
Loop::defer([$connection, 'handle_messages']);
|
||||||
|
|
||||||
if ($shared->isHttp()) {
|
if ($shared->isHttp()) {
|
||||||
Loop::defer([$connection->waiter, 'resume']);
|
Loop::defer([$connection, 'pingHttpWaiter']);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user