Skip to content

Commit 9054aef

Browse files
Merge v1.x into v2.x (#1417)
2 parents 4cdf568 + dac8b8f commit 9054aef

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Operation/Watch.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -315,7 +315,7 @@ final public function commandSucceeded(CommandSucceededEvent $event): void
315315
}
316316

317317
if (
318-
$this->shouldCaptureOperationTime($event->getServer()) &&
318+
$this->shouldCaptureOperationTime() &&
319319
isset($reply->operationTime) && $reply->operationTime instanceof TimestampInterface
320320
) {
321321
$this->operationTime = $reply->operationTime;
@@ -431,7 +431,7 @@ private function resume(array|object|null $resumeToken = null, bool $hasAdvanced
431431
*
432432
* @see https://github.com/mongodb/specifications/blob/master/source/change-streams/change-streams.rst#startatoperationtime
433433
*/
434-
private function shouldCaptureOperationTime(Server $server): bool
434+
private function shouldCaptureOperationTime(): bool
435435
{
436436
if ($this->hasResumed) {
437437
return false;

0 commit comments

Comments
 (0)