stream_select with rabbitmq example

example.php

<?php
/*
Some code here

More info here (Russian): https://www.facebook.com/vtvz.ru/posts/1612858868772444
*/
$stdin = fopen('php://stdin', 'r');
$rabbitmq = $connection->getSocket();
while (count($channel->callbacks)) {
    $read = [$rabbitmq, $stdin];
    $write = null;
    $except = null;
    if (false === ($changeStreamsCount = stream_select($read, $write, $except, 60))) {
        // Error handling
    } elseif ($changeStreamsCount > 0) {
        foreach ($read as $fd) {
            if ($fd === $stdin) {
                $line = fgets($stdin);
                //Do something with input data
            } elseif ($fd === $rabbitmq) {
                $channel->wait();
            }
        }
    }
}