Online PHP editor | refs for Oq2st

<?php $gen = function ($client, $stream) { while ($record = yield) { yield [ 'StreamName' => $stream, 'PartitionKey' => 'group' . rand(1, 5), 'Data' => $record, ]; } }; $records = $gen('things'); while ($records->valid()) { var_dump($records->current()); $records->next(); } $records->send('<Record Data>'); $records->send('<Record Data>'); while ($records->valid()) { var_dump($records->current()); $records->next(); } $records->send('<Record Data>'); $records->send('<Record Data>'); while ($records->valid()) { var_dump($records->current()); $records->next(); } $records->send('<Record Data>'); $records->send('<Record Data>'); $records->send('<Record Data>'); $records->send('<Record Data>'); $records->send('<Record Data>'); $records->send('<Record Data>'); while ($records->valid()) { var_dump($records->current()); $records->next(); }