11 include "helper/server.inc";
15 class Client extends http\Client {
18 class ProgressObserver1 implements SplObserver {
19 #[ReturnTypeWillChange]
20 function update(SplSubject $c, $r = null) {
21 if ($c->getProgressInfo($r)) $c->pi .= "-";
24 class ProgressObserver2 implements SplObserver {
25 #[ReturnTypeWillChange]
26 function update(SplSubject $c, $r = null) {
27 if ($c->getProgressInfo($r)) $c->pi .= ".";
30 class CallbackObserver implements SplObserver {
32 function __construct($callback) {
33 $this->callback = $callback;
35 #[ReturnTypeWillChange]
36 function update(SplSubject $c, $r = null) {
37 call_user_func($this->callback, $c, $r);
41 server("proxy.inc", function($port) {
43 $client->attach($o1 = new ProgressObserver1);
44 $client->attach($o2 = new ProgressObserver2);
46 $o3 = new CallbackObserver(
48 $p = (array) $c->getProgressInfo($r);
52 var_dump(array_key_exists("started", $p));
53 var_dump(array_key_exists("finished", $p));
54 var_dump(array_key_exists("dlnow", $p));
55 var_dump(array_key_exists("ulnow", $p));
56 var_dump(array_key_exists("dltotal", $p));
57 var_dump(array_key_exists("ultotal", $p));
58 var_dump(array_key_exists("info", $p));
63 $client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"))->send();
64 var_dump(1 === preg_match("/(\.-)+/", $client->pi));
65 var_dump(3 === count($client->getObservers()));
67 var_dump(2 === count($client->getObservers()));
69 var_dump(1 === count($client->getObservers()));
71 var_dump(0 === count($client->getObservers()));
78 Test\n(bool\(true\)\n)+Done