git.m6w6.name Git - m6w6/ext-http/blob - tests/client013.phpt

   1 --TEST--
   2 client observers
   3 --SKIPIF--
   4 <?php
   5 include "skipif.inc";
   6 skip_client_test();
   7 ?>
   8 --FILE--
   9 <?php
  10
  11 include "helper/server.inc";
  12
  13 echo "Test\n";
  14
  15 class Client extends http\Client {
  16         public $pi;
  17 }
  18 class ProgressObserver1 implements SplObserver {
  19         function update(SplSubject $c, $r = null) {
  20                 if ($c->getProgressInfo($r)) $c->pi .= "-";
  21         }
  22 }
  23 class ProgressObserver2 implements SplObserver {
  24         function update(SplSubject $c, $r = null) {
  25                 if ($c->getProgressInfo($r)) $c->pi .= ".";
  26         }
  27 }
  28 class CallbackObserver implements SplObserver {
  29         public $callback;
  30         function __construct($callback) {
  31                 $this->callback = $callback;
  32         }
  33         function update(SplSubject $c, $r = null) {
  34                 call_user_func($this->callback, $c, $r);
  35         }
  36 }
  37
  38 server("proxy.inc", function($port) {
  39         $client = new Client;
  40         $client->attach($o1 = new ProgressObserver1);
  41         $client->attach($o2 = new ProgressObserver2);
  42         $client->attach(
  43                         $o3 = new CallbackObserver(
  44                                         function ($c, $r) {
  45                                                 $p = (array) $c->getProgressInfo($r);
  46                                                 if (!$p) {
  47                                                         return;
  48                                                 }
  49                                                 var_dump(array_key_exists("started", $p));
  50                                                 var_dump(array_key_exists("finished", $p));
  51                                                 var_dump(array_key_exists("dlnow", $p));
  52                                                 var_dump(array_key_exists("ulnow", $p));
  53                                                 var_dump(array_key_exists("dltotal", $p));
  54                                                 var_dump(array_key_exists("ultotal", $p));
  55                                                 var_dump(array_key_exists("info", $p));
  56                                         }
  57                         )
  58         );
  59
  60         $client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"))->send();
  61         var_dump(1 === preg_match("/(\.-)+/", $client->pi));
  62         var_dump(3 === count($client->getObservers()));
  63         $client->detach($o1);
  64         var_dump(2 === count($client->getObservers()));
  65         $client->detach($o2);
  66         var_dump(1 === count($client->getObservers()));
  67         $client->detach($o3);
  68         var_dump(0 === count($client->getObservers()));
  69
  70 });
  71
  72 ?>
  73 Done
  74 --EXPECTREGEX--
  75 Test\n(bool\(true\)\n)+Done