example for pubsub?

[amphp]

example for pubsub?

[kelunik]

It seems you somehow mixed Amp v2 and v3. With Revolt / Amp v3, you don't need to explicitly run the event loop or use yield. I've added an example in 32350df now.

[fayland]

it seems blocking. can we have a non-blocking example?

foreach ($subscription as $message) {
    echo "Got " . $message . " on " . date('Y-m-d H:i:s') . "\n";
    __handle($message);
}

function __handle($msg) {
    sleep(30);
    return;
}

can use function Amp\ParallelFunctions\parallelMap;?
basically we want to process the message as fast as possible.

Thanks

[kelunik]

It is non-blocking using Fibers, otherwise the example would block at the foreach and never run the async block. delay() is the non-blocking sleep equivalent.