Skip to content

Commit c7e778c

Browse files
authored
新增支持泛型注释,增强IDE提示能力 (#166)
1 parent c6f32ba commit c7e778c

3 files changed

+6
-3
lines changed

src/Driver/RedisQueueDriver.php

+2-1
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,8 @@ public function pop(float $timeout = -1): ?IMessage
239239
{
240240
return null;
241241
}
242-
} while (($useTime = (microtime(true) - $time)) < $timeout);
242+
}
243+
while (($useTime = (microtime(true) - $time)) < $timeout);
243244

244245
return null;
245246
}

src/Partial/SwooleBaseQueueConsumerPartial.php

+2-1
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,8 @@ public function start(?int $co = null): void
7575
{
7676
App::getBean('ErrorLog')->onException($th);
7777
}
78-
} while ($this->working);
78+
}
79+
while ($this->working);
7980
};
8081
if ($co > 0)
8182
{

src/Partial/WorkermanBaseQueueConsumerPartial.php

+2-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,8 @@ public function start(?int $co = null): void
5858
{
5959
App::getBean('ErrorLog')->onException($th);
6060
}
61-
} while ($this->working);
61+
}
62+
while ($this->working);
6263
}
6364

6465
/**

0 commit comments

Comments
 (0)