--- /dev/null
+<?php
+
+
+class EvHandler implements http\Client\Curl\User
+{
+ private $client;
+ private $run;
+ private $ios = [];
+ private $timeout;
+
+ function __construct(http\Client $client) {
+ $this->client = $client;
+ }
+
+ function init($run) {
+ $this->run = $run;
+ }
+
+ function timer(int $timeout_ms) {
+ if (isset($this->timeout)) {
+ $this->timeout->set($timeout_ms/1000, 0);
+ $this->timeout->start();
+ } else {
+ $this->timeout = new EvTimer($timeout_ms/1000, 0, function() {
+ if (!call_user_func($this->run, $this->client)) {
+ if ($this->timeout) {
+ $this->timeout->stop();
+ $this->timeout = null;
+ }
+ }
+ });
+ }
+ }
+
+ function socket($socket, int $action) {
+ switch ($action) {
+ case self::POLL_NONE:
+ break;
+ case self::POLL_REMOVE:
+ echo "U";
+ if (isset($this->ios[(int) $socket])) {
+ $this->ios[(int) $socket]->stop();
+ unset($this->ios[(int) $socket]);
+ }
+ break;
+ default:
+ $ev = 0;
+ if ($action & self::POLL_IN) {
+ $ev |= Ev::READ;
+ }
+ if ($action & self::POLL_OUT) {
+ $ev |= Ev::WRITE;
+ }
+ if (isset($this->ios[(int) $socket])) {
+ $this->ios[(int) $socket]->set($socket, $ev);
+ } else {
+ $this->ios[(int) $socket] = new EvIo($socket, $ev, function($watcher, $events) use($socket) {
+ $action = 0;
+ if ($events & Ev::READ) {
+ $action |= self::POLL_IN;
+ }
+ if ($events & Ev::WRITE) {
+ $action |= self::POLL_OUT;
+ }
+ if (!call_user_func($this->run, $this->client, $socket, $action)) {
+ if ($this->timeout) {
+ $this->timeout->stop();
+ $this->timeout = null;
+ }
+ }
+ });
+ }
+ break;
+ }
+ }
+
+ function once() {
+ echo "O";
+ Ev::run(EV::RUN_NOWAIT);
+ }
+ function wait(int $timeout_ms = null) {
+ echo "W";
+ Ev::run(EV::RUN_ONCE);
+ }
+ function send() {
+ echo "!";
+ Ev::verify();
+ Ev::run();
+ }
+}