modify plugin name
This commit is contained in:
@@ -40,6 +40,9 @@ class PoolQueue implements QueueInterface
|
|||||||
*/
|
*/
|
||||||
public function push(mixed $data, float $timeout = -1): bool
|
public function push(mixed $data, float $timeout = -1): bool
|
||||||
{
|
{
|
||||||
|
if ($this->isFull()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
if (!$this->isClose()) {
|
if (!$this->isClose()) {
|
||||||
return $this->queue->push($data, $timeout);
|
return $this->queue->push($data, $timeout);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -44,6 +44,9 @@ class SplQueue implements QueueInterface
|
|||||||
public function push(mixed $data, float $timeout = -1): bool
|
public function push(mixed $data, float $timeout = -1): bool
|
||||||
{
|
{
|
||||||
// TODO: Implement push() method.
|
// TODO: Implement push() method.
|
||||||
|
if ($this->isFull()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
$this->channel->enqueue($data);
|
$this->channel->enqueue($data);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user