Skip to content

use str_increment() when possible to increment non-numeric strings #110

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Aug 27, 2025
Merged

use str_increment() when possible to increment non-numeric strings #110

Changes from 3 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
8596d87
use str_increment() when possible to increment non-numeric strings
xabbuh Aug 25, 2025
d0d5a90
Fix code style
kelunik Aug 27, 2025
23182c5
Suppress psalm error for str_increment
kelunik Aug 27, 2025
0bc51f5
Fix code style settings
kelunik Aug 27, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 20 additions & 6 deletions src/EventLoop/Internal/AbstractDriver.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ public function queue(\Closure $closure, mixed ...$args): void

public function defer(\Closure $closure): string
{
$deferCallback = new DeferCallback($this->nextId++, $closure);
$deferCallback = new DeferCallback($this->callbackId(), $closure);

$this->callbacks[$deferCallback->id] = $deferCallback;
$this->enableDeferQueue[$deferCallback->id] = $deferCallback;
Expand All @@ -155,7 +155,7 @@ public function delay(float $delay, \Closure $closure): string
throw new \Error("Delay must be greater than or equal to zero");
}

$timerCallback = new TimerCallback($this->nextId++, $delay, $closure, $this->now() + $delay);
$timerCallback = new TimerCallback($this->callbackId(), $delay, $closure, $this->now() + $delay);

$this->callbacks[$timerCallback->id] = $timerCallback;
$this->enableQueue[$timerCallback->id] = $timerCallback;
Expand All @@ -169,7 +169,7 @@ public function repeat(float $interval, \Closure $closure): string
throw new \Error("Interval must be greater than or equal to zero");
}

$timerCallback = new TimerCallback($this->nextId++, $interval, $closure, $this->now() + $interval, true);
$timerCallback = new TimerCallback($this->callbackId(), $interval, $closure, $this->now() + $interval, true);

$this->callbacks[$timerCallback->id] = $timerCallback;
$this->enableQueue[$timerCallback->id] = $timerCallback;
Expand All @@ -179,7 +179,7 @@ public function repeat(float $interval, \Closure $closure): string

public function onReadable(mixed $stream, \Closure $closure): string
{
$streamCallback = new StreamReadableCallback($this->nextId++, $closure, $stream);
$streamCallback = new StreamReadableCallback($this->callbackId(), $closure, $stream);

$this->callbacks[$streamCallback->id] = $streamCallback;
$this->enableQueue[$streamCallback->id] = $streamCallback;
Expand All @@ -189,7 +189,7 @@ public function onReadable(mixed $stream, \Closure $closure): string

public function onWritable($stream, \Closure $closure): string
{
$streamCallback = new StreamWritableCallback($this->nextId++, $closure, $stream);
$streamCallback = new StreamWritableCallback($this->callbackId(), $closure, $stream);

$this->callbacks[$streamCallback->id] = $streamCallback;
$this->enableQueue[$streamCallback->id] = $streamCallback;
Expand All @@ -199,7 +199,7 @@ public function onWritable($stream, \Closure $closure): string

public function onSignal(int $signal, \Closure $closure): string
{
$signalCallback = new SignalCallback($this->nextId++, $closure, $signal);
$signalCallback = new SignalCallback($this->callbackId(), $closure, $signal);

$this->callbacks[$signalCallback->id] = $signalCallback;
$this->enableQueue[$signalCallback->id] = $signalCallback;
Expand Down Expand Up @@ -640,6 +640,20 @@ private function createErrorCallback(): void
};
}

private function callbackId(): string
{
$callbackId = $this->nextId;

if (\PHP_VERSION_ID >= 80300) {
/** @psalm-suppress UndefinedFunction */
$this->nextId = \str_increment($this->nextId);
} else {
$this->nextId++;
}

return $callbackId;
}

final public function __serialize(): never
{
throw new \Error(__CLASS__ . ' does not support serialization');
Expand Down
Loading