amp/examples/streams/producer.php

#!/usr/bin/env php
<?php

require __DIR__ . '/../../vendor/autoload.php';

use Amp\Coroutine;
use Amp\Delayed;
use Amp\Loop;
use Amp\Producer;
use Amp\Stream;
use Amp\StreamIterator;

Loop::run(function () {
    try {
        $producer = new Producer(function (callable $emit) {
            yield $emit(1);
            yield $emit(new Delayed(500, 2));
            yield $emit(3);
            yield $emit(new Delayed(300, 4));
            yield $emit(5);
            yield $emit(6);
            yield $emit(new Delayed(1000, 7));
            yield $emit(8);
            yield $emit(9);
            yield $emit(new Delayed(600, 10));
            return 11;
        });

        $generator = function (Stream $stream) {
            $listener = new StreamIterator($stream);

            while (yield $listener->advance()) {
                printf("Stream emitted %d\n", $listener->getCurrent());
                yield new Delayed(100); // Listener consumption takes 100 ms.
            }

            printf("Stream result %d\n", $listener->getResult());
        };

        yield new Coroutine($generator($producer));
    } catch (\Exception $exception) {
        printf("Exception: %s\n", $exception);
    }
});