CircularQueue::pull() - Code Metrics - Insolita/circular-queue - Measure and Improve Code Quality continuously with Scrutinizer

CircularQueue::pull() A
last analyzed 2019-10-22 06:23 UTC

↳ Parent: CircularQueue

Complexity

Conditions	3
Paths	3

Size

Total Lines	12
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	9
c	1
b	0
f	0
dl	0
loc	12
rs	9.9666
cc	3
nc	3
nop	1

<?php
/**
 * Created by solly [31.10.17 15:41]
 */

namespace insolita\cqueue;

use Carbon\Carbon;
use insolita\cqueue\Contracts\DelayingInterface;
use insolita\cqueue\Mixins\DelayingTrait;

class CircularQueue extends SimpleCircularQueue implements DelayingInterface
{
    use DelayingTrait;

    
    public function countTotal():int
    {
        return $this->countQueued() + $this->countDelayed();
    }
    
    public function next()
    {
        $this->beforePull();
        return parent::next();
    }
    
    public function pull(int $ttl = 0)
    {
        $this->beforePull();
        $item = $this->storage->listPop($this->queueKey());
        if (!$item) {
            return $this->emptyQueueBehavior->resolve($this);
        } else {
            if ($ttl > 0) {
                $resumeTime = Carbon::now()->timestamp + $ttl;
                $this->storage->zSetPush($this->delayedKey(), $resumeTime, $item);
            }
            return $this->converter->toPayload($item);
        }
    }
    
    protected function beforePull()
    {
        $this->resumeExpired();
    }
}


1			<?php
2			/**
3			* Created by solly [31.10.17 15:41]
4			*/
5
6			namespace insolita\cqueue;
7
8			use Carbon\Carbon;
9			use insolita\cqueue\Contracts\DelayingInterface;
10			use insolita\cqueue\Mixins\DelayingTrait;
11
12			class CircularQueue extends SimpleCircularQueue implements DelayingInterface
13			{
14			use DelayingTrait;
			0 ignored issues – show Bug introduced 2018-04-09 15:00 UTC by Report Bug Copy Issue Report The trait `insolita\cqueue\Mixins\DelayingTrait` requires the property `$timestamp` which is not provided by `insolita\cqueue\CircularQueue`. Loading history...
15
16			public function countTotal():int
17			{
18			return $this->countQueued() + $this->countDelayed();
19			}
20
21			public function next()
22			{
23			$this->beforePull();
24			return parent::next();
25			}
26
27			public function pull(int $ttl = 0)
28			{
29			$this->beforePull();
30			$item = $this->storage->listPop($this->queueKey());
31			if (!$item) {
32			return $this->emptyQueueBehavior->resolve($this);
33			} else {
34			if ($ttl > 0) {
35			$resumeTime = Carbon::now()->timestamp + $ttl;
36			$this->storage->zSetPush($this->delayedKey(), $resumeTime, $item);
37			}
38			return $this->converter->toPayload($item);
39			}
40			}
41
42			protected function beforePull()
43			{
44			$this->resumeExpired();
45			}
46			}
47

Insolita / circular-queue

CircularQueue::pull() A last analyzed 2019-10-22 06:23 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

CircularQueue::pull() A
last analyzed 2019-10-22 06:23 UTC