expressif/stream

evented streams wrapper

Streams with libevent

Evented streams wrapper (used by expressif/http and expressif/cluster), _(*1)

Requirements

• php 5.6+
• libevent 0.1.0

Installation

Get the libevent library from pecl : http://php.net/manual/fr/libevent.installation.php, _(*2)

Note : For windows you can download libraries from here : https://github.com/expressif/win-dist, _(*3)

Add this lib as a dependency composer require expressif/stream, _(*4)

Usage

EventEmitter

This class handles callback listeners and events emission :, _(*5)

<?php
  require 'vendor/autoload.php';
  use Expressif\Stream\EventEmitter;

  class Foo extends EventEmitter {
    public function bar() {
      $this->emit('bar', ['baz']);
    }
  }

  $foo = new Foo();
  $foo->on('bar', function($what) {
    echo "Foo $what !\n";
  });
  $foo->bar();

Timers

This helper provides a way to periodically executes specified code :, _(*6)

<?php
  require 'vendor/autoload.php';
  use Expressif\Stream\Loop;
  Loop::setInterval(function() {
    echo 'Now is ' . date('H:i:s') . "\n";
  }, 1000);

Buffers

This class handles buffered reads and writes :, _(*7)

<?php
  require 'vendor/autoload.php';
  use Expressif\Stream\Loop;

  $buffer = Loop::buffer('tcp://173.194.66.104:80');
  $buffer->read(function($response) {
    echo '<- ' . $response;
  });
  $buffer->on('write', function() {
    echo "-> Request sent\n";
  });
  $buffer->on('close', function() {
    echo "*** response is finished ***\n";
  });
  $buffer->write("GET / HTTP/1.0\r\nHost: www.google.com\r\n\r\n");