refactor

[m6w6/seekat] / examples / ev.php

diff --git a/examples/ev.php b/examples/ev.php
new file mode 100644 (file)
index 0000000..5cc5bae
--- /dev/null
+++ b/examples/ev.php
@@ -0,0 +1,90 @@
+<?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();
+       }
+}