README

此组件是不同类型PHP流的包装器

用法

本包的类允许您以非阻塞的方式处理文件、套接字、管道、输入/输出流等流

use Phasty\Stream\Stream;
use Phasty\Stream\StreamSet;
use Phasty\Stream\Timer;

// use wrapper for STDIN
$readStream = new Stream(STDIN);
// streamset allows you work with different streams at sames time tih interraptions for timers
$streamSet = StreamSet::instance();
$streamSet->addReadStream($readStream);
$readStream->on("data", function($event) use ($streamSet) {
    $data = $event->getData();
    if (trim($data) === "q") {
        $streamSet->stop();
        return;
    }
    echo "you wrote: " . $event->getData();
});
$timer = new Timer(2, 0, function() { 
    echo "Now: " . date("H:i:s"), "\n";
});
$streamSet->addTimer($timer);
$streamSet->listen();
echo "exiting\n";

您将得到类似以下内容

Now: 20:52:11
dawd
you wrote: dawd
Now: 20:52:13
q
exiting

phasty / stream

维护者

详细信息

README

用法