f246a30c850a36a83879c14f06b6a36194c8b19d
[m6w6/ext-http] / 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 "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 var_dump(array_key_exists("started", $p));
47 var_dump(array_key_exists("finished", $p));
48 var_dump(array_key_exists("dlnow", $p));
49 var_dump(array_key_exists("ulnow", $p));
50 var_dump(array_key_exists("dltotal", $p));
51 var_dump(array_key_exists("ultotal", $p));
52 var_dump(array_key_exists("info", $p));
53 }
54 )
55 );
56
57 $client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"))->send();
58 var_dump(1 === preg_match("/(\.-)+/", $client->pi));
59 var_dump(3 === count($client->getObservers()));
60 $client->detach($o1);
61 var_dump(2 === count($client->getObservers()));
62 $client->detach($o2);
63 var_dump(1 === count($client->getObservers()));
64 $client->detach($o3);
65 var_dump(0 === count($client->getObservers()));
66
67 });
68
69 ?>
70 Done
71 --EXPECTREGEX--
72 Test\n(bool\(true\)\n)+Done