stream.php

<?php

$confirmedEmails = yield $db->select()
  ->stream()
  ->filter(fn (User $user) => $user->isEmailConfirmed())
  ->map(fn (User $user) => $user->getEmail())
  ->toArray();

$pagedConfirmedUsers = yield $db->select()
  ->stream()
  ->filter(fn (User $user) => $user->isEmailConfirmed())
  ->skip(10 * ($page - 1))
  ->limit(10)
  ->toArray();

• map(callable): Stream
• filter(callable): Stream
• each(callable): Promise
• drop(int): Stream / skip(int): Stream
• dropWhile(callable): Stream / skipWhile(callable): Stream
• dropUntil(callable): Stream / skipUntil(callable): Stream
• limit(int): Stream / take(int): Stream
• count(): Promise
• sum(): Promise
• toArray(): Promise