Skip to content

Commit ae4b72f

Browse files
authored
引入 Rector、优化代码 (#242)
1 parent 06d3c56 commit ae4b72f

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

rector.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
return getRectorConfigCallback(__DIR__);

src/Aspect/WorkerLimitAspect.php

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -43,17 +43,11 @@ public function parse(AroundJoinPoint $joinPoint)
4343
$blockingConsumer = AnnotationManager::getMethodAnnotations($className, $method, BlockingConsumer::class)[0] ?? null;
4444
if (null === $blockingConsumer)
4545
{
46-
$result = WorkerLimiter::call(function () use ($joinPoint) {
47-
return $joinPoint->proceed();
48-
}, $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $workerLimit->callback, $workerLimit->poolName);
46+
return WorkerLimiter::call(fn () => $joinPoint->proceed(), $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $workerLimit->callback, $workerLimit->poolName);
4947
}
5048
else
5149
{
52-
$result = WorkerLimiter::callBlock(function () use ($joinPoint) {
53-
return $joinPoint->proceed();
54-
}, $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $blockingConsumer->timeout, $workerLimit->callback, $workerLimit->poolName);
50+
return WorkerLimiter::callBlock(fn () => $joinPoint->proceed(), $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $blockingConsumer->timeout, $workerLimit->callback, $workerLimit->poolName);
5551
}
56-
57-
return $result;
5852
}
5953
}

0 commit comments

Comments
 (0)