diff --git a/src/Operation/Watch.php b/src/Operation/Watch.php index d8a1a9f27..7e192b298 100644 --- a/src/Operation/Watch.php +++ b/src/Operation/Watch.php @@ -317,7 +317,7 @@ final public function commandSucceeded(CommandSucceededEvent $event): void } if ( - $this->shouldCaptureOperationTime($event->getServer()) && + $this->shouldCaptureOperationTime() && isset($reply->operationTime) && $reply->operationTime instanceof TimestampInterface ) { $this->operationTime = $reply->operationTime; @@ -433,7 +433,7 @@ private function resume(array|object|null $resumeToken = null, bool $hasAdvanced * * @see https://github.com/mongodb/specifications/blob/master/source/change-streams/change-streams.rst#startatoperationtime */ - private function shouldCaptureOperationTime(Server $server): bool + private function shouldCaptureOperationTime(): bool { if ($this->hasResumed) { return false;