Skip to content

Commit 8f634dd

Browse files
committed
Use decode() instead of decodeIfSupported()
1 parent c3a3164 commit 8f634dd

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

src/ChangeStream.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ public function current()
114114
return $value;
115115
}
116116

117-
return $this->codec->decodeIfSupported($value);
117+
return $this->codec->decode($value);
118118
}
119119

120120
/** @return CursorId */

src/Operation/FindAndModify.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -262,8 +262,7 @@ public function execute(Server $server)
262262
$result = current($cursor->toArray());
263263
assert($result instanceof Document);
264264

265-
$decoded = $this->options['codec']->decodeIfSupported($result->get('value'));
266-
assert($decoded === null || is_object($decoded));
265+
$decoded = $this->options['codec']->decode($result->get('value'));
267266

268267
return $decoded;
269268
}

0 commit comments

Comments
 (0)