1
0
mirror of https://github.com/danog/amp.git synced 2024-12-12 17:37:34 +01:00
amp/examples/iterators/backpressure.php

40 lines
1.1 KiB
PHP
Raw Normal View History

2016-05-27 01:20:05 +02:00
#!/usr/bin/env php
<?php
require __DIR__ . '/../../vendor/autoload.php';
2016-05-27 01:20:05 +02:00
use Amp\Delayed;
use Amp\Emitter;
use Amp\Loop;
2017-05-03 15:21:49 +02:00
use function Amp\asyncCall;
2016-05-27 01:20:05 +02:00
Loop::run(function () {
2016-05-27 01:20:05 +02:00
try {
2017-01-04 02:10:27 +01:00
$emitter = new Emitter;
2017-05-01 07:29:23 +02:00
$iterator = $emitter->iterate();
2016-05-27 22:44:01 +02:00
2017-01-04 02:10:27 +01:00
$generator = function (Emitter $emitter) {
yield $emitter->emit(new Delayed(500, 1));
yield $emitter->emit(new Delayed(1500, 2));
yield $emitter->emit(new Delayed(1000, 3));
yield $emitter->emit(new Delayed(2000, 4));
2017-01-04 02:10:27 +01:00
yield $emitter->emit(5);
yield $emitter->emit(6);
yield $emitter->emit(7);
yield $emitter->emit(new Delayed(2000, 8));
2017-01-04 02:10:27 +01:00
yield $emitter->emit(9);
yield $emitter->emit(10);
2017-04-27 17:51:06 +02:00
$emitter->complete();
2016-05-27 01:20:05 +02:00
};
2017-05-03 15:21:49 +02:00
asyncCall($generator, $emitter);
2017-04-27 17:51:06 +02:00
while (yield $iterator->advance()) {
\printf("Emitter emitted %d\n", $iterator->getCurrent());
yield new Delayed(500); // Listener consumption takes 500 ms.
}
2016-05-27 01:20:05 +02:00
} catch (\Exception $exception) {
\printf("Exception: %s\n", $exception);
2016-05-27 01:20:05 +02:00
}
});