diff --git a/src/Operation/Watch.php b/src/Operation/Watch.php index 99e0f0380..f6f51f73d 100644 --- a/src/Operation/Watch.php +++ b/src/Operation/Watch.php @@ -324,7 +324,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; @@ -445,7 +445,7 @@ private function resume($resumeToken = null, bool $hasAdvanced = false): ChangeS * * @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;