for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/*
* This file is part of the Phive Queue package.
*
* (c) Eugene Leonovich <[email protected]>
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Phive\Queue;
class TypeSafeQueue implements Queue
{
/**
* @var Queue
private $queue;
public function __construct(Queue $queue)
$this->queue = $queue;
}
* {@inheritdoc}
public function push($item, $eta = null)
$item = base64_encode(serialize($item));
$this->queue->push($item, $eta);
public function pop()
$item = $this->queue->pop();
return unserialize(base64_decode($item));
public function count()
return $this->queue->count();
public function clear()
$this->queue->clear();