danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2025-01-22 21:31:18 +01:00
Code Issues Projects Releases Wiki Activity

Throw if Future::iterate() is provided something other than futures

Browse Source
This commit is contained in:
Aaron Piotrowski 2021-09-17 14:52:07 -05:00
parent 0d3f068fbf
commit b63b26b063
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/Future.php
View File

@ -30,6 +30,9 @@ final class Future
// Directly iterate in case of an array, because there can't be suspensions during iteration // Directly iterate in case of an array, because there can't be suspensions during iteration
if (\is_array($futures)) { if (\is_array($futures)) {
foreach ($futures as $key => $future) { foreach ($futures as $key => $future) {
if (!$future instanceof self) {
throw new \TypeError('Array must only contain instances of ' . self::class);
}
$iterator->enqueue($future->state, $key, $future); $iterator->enqueue($future->state, $key, $future);
} }
$iterator->complete(); $iterator->complete();
@ -39,6 +42,9 @@ final class Future
defer(static function () use ($futures, $iterator): void { defer(static function () use ($futures, $iterator): void {
try { try {
foreach ($futures as $key => $future) { foreach ($futures as $key => $future) {
if (!$future instanceof self) {
throw new \TypeError('Iterable must only provide instances of ' . self::class);
}
$iterator->enqueue($future->state, $key, $future); $iterator->enqueue($future->state, $key, $future);
} }
$iterator->complete(); $iterator->complete();