flush docs

[mdref/mdref-http] / http / Client / Curl / User / : Examples.md

diff --git a/http/Client/Curl/User/: Examples.md b/http/Client/Curl/User/: Examples.md
new file mode 100644 (file)
index 0000000..4c732c7
--- /dev/null
+++ b/http/Client/Curl/User/: Examples.md
@@ -0,0 +1,112 @@
+# http\Client\Curl\User Examples
+
+## Example using the [pecl/ev](http://pecl.php.net/ev) loop:
+
+       <?php
+
+       class UserHandler implements http\Client\Curl\User
+       {
+               private $client;
+               private $run;
+               private $ios = [];
+               private $timeout;
+
+
+               function __construct(http\Client $client) {
+                       $this->client = $client;
+               }
+
+               function init(callable $run) {
+                       $this->run = $run;
+               }
+
+               function timer(int $timeout_ms) {
+                       echo "T";
+                       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) {
+                       echo "S";
+
+                       switch ($action) {
+                       case self::POLL_NONE:
+                               break;
+                       case self::POLL_REMOVE:
+                               if (isset($this->ios[(int) $socket])) {
+                                       echo "U";
+                                       $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() {
+                       throw new BadMethodCallException("this example uses Ev::run()");
+               }
+
+               function wait(int $timeout_ms = null) {
+                       throw new BadMethodCallException("this example uses Ev::run()");
+               }
+
+               function send() {
+                       throw new BadMethodCallException("this example uses Ev::run()");
+               }
+       }
+
+       $client = new http\Client;
+       $client->configure([
+                       "use_eventloop" => new UserHandler($client)
+       ]);
+       $client->enqueue(new http\Client\Request("GET", "http://example.com/"), function($r) {
+               var_dump($r->getResponseCode());
+       });
+
+       Ev::run();
+
+       ?>
+
+### Yields:
+
+       TTTTTTTTSTSTSUint(200)