modify plugin name
This commit is contained in:
@@ -58,14 +58,12 @@ class Pool extends Component
|
|||||||
protected function pop(PoolQueue $channel, $retain_number): void
|
protected function pop(PoolQueue $channel, $retain_number): void
|
||||||
{
|
{
|
||||||
while ($channel->length() > $retain_number) {
|
while ($channel->length() > $retain_number) {
|
||||||
if (Context::inCoroutine()) {
|
$connection = $channel->pop(0.001);
|
||||||
$connection = $channel->pop();
|
|
||||||
if ($connection instanceof StopHeartbeatCheck) {
|
if ($connection instanceof StopHeartbeatCheck) {
|
||||||
$connection->stopHeartbeatCheck();
|
$connection->stopHeartbeatCheck();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Reference in New Issue
Block a user