Da

ftypavif mif1avifmiaf Ömeta !hdlr pict pitm "iloc D@ ú :¤ #iinf infe av01 Viprp 8ipco av1C! ispe € h pixi ipma :¬mdat 8f'û;Hh4€2“u˜É(a†È oÏÍª"ÂøÐKôÃn×½àÄ¶ïÏõ*û?Df²[a²„ël×Ê2c¾5MEÓWønxUFçŠVó’ïkPÔ‘ð‚…4|¡Ûà:ŠØØòƒ4EáÆgzË6b’YZs§»¬BçÜ i‹‚ÙØ`ÄK÷>ºê4äüN«¯Yõ²MøÉßp¦5ÆË4,Øt `Ðœ‘ûìùcåÀ6öq½ü´“æ?æ2ÑÇÚ—FQŠÛº x€dÜ%á!~[7¼&¨d‘SYƒîQä•+3%)¢©t¨æÖËœ5ˆªi%ï>#OŒÐÙxœP®++¼xRë.Ìíam)§FGsdágª2£c—øuk²ã| ÞeÀž?çå‡~/ïÕœu™å¢$x†˜àn±Ã…LÜ ZkÀº÷Ø¿8ÒšMÏÈ`ØÿÓ‘žòl’ƒri;W?SDB Í}R#hï‹?!¯Ç¾[\ê=h˜ò~K©³ÄÝMUp_åµš™k6)c¥*~àýÏÚ Ô->h4SZ”„¹©¼MdÂÀc“çÄèúµ†Ñ›¥«…Üû)©£U»X…]*éµÇ2éÚ`ª–ìÔ%“èÏR;‰ý—<—/#vÒ(|4©[mä“C3bêVóšèfw¥ÁðFAâ D"º”ß¼À!g7òà¢ª¿ŠÊJIl“‘^EµmMr.DÝ«Äaß ´Ùˆí‹½[Iª‹6°§9öŠovu±HÓÑIVƒU˜ ¾¤”YcO=~_ÓGÝÅç˜óÄO\ñ%'3ô?º¢r· ¤CûêJ3.}a¯¿.~çË©õžºÔŒ¨ÉnéU¦0LrVM:@ O`Óõ¤[QË¦Éx€XØý0\z³UŸx>šPá÷¹SÚ¹¿šû¡6}N Da

🏠 Root / opt / alt / tests / alt-php81-pecl-http_4.2.6-4.el8 / tests /

✏️ Editing: client029.phpt

--TEST--
client curl user handler
--SKIPIF--
<?php 
include "skipif.inc";
skip_client_test();
_ext("event");
?> 
--FILE--
<?php 
echo "Test\n";

class UserHandler implements http\Client\Curl\User
{
	private $evbase;
	private $client;
	private $run;
	private $ios = [];
	private $timeout;

function __construct(http\Client $client, EventBase $evbase) {
		$this->evbase = $evbase;
		$this->client = $client;
	}
	
	function init($run) {
		$this->run = $run;
	}
	
	function timer(int $timeout_ms) {
		echo "T";
		if (isset($this->timeout)) {
			$this->timeout->add($timeout_ms/1000);
		} else {
			$this->timeout = Event::timer($this->evbase, function() {
				if (!call_user_func($this->run, $this->client)) {
					if ($this->timeout) {
						$this->timeout->del();
						$this->timeout = null;
					}
				}
			});
			$this->timeout->add($timeout_ms/1000);
		}
	}
	
	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]->del();
				unset($this->ios[(int) $socket]);
			}
			break;
			
		default:
			$ev = 0;
			if ($action & self::POLL_IN) {
				$ev |= Event::READ;
			}
			if ($action & self::POLL_OUT) {
				$ev |= Event::WRITE;
			}
			if (isset($this->ios[(int) $socket])) {
				$this->ios[(int) $socket]->set($this->evbase, 
						$socket, $ev, $this->onEvent($socket));
			} else {
				$this->ios[(int) $socket] = new Event($this->evbase, 
						$socket, $ev, $this->onEvent($socket));
			}
			break;
		}
	}
	
	function onEvent($socket) {
		return 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->del();
					$this->timeout = null;
				}
			}
		};
	}
	
	function once() {
		throw new BadMethodCallException("this test uses EventBase::loop()");
	}
	
	function wait(int $timeout_ms = null) {
		throw new BadMethodCallException("this test uses EventBase::loop()");
	}
	
	function send() {
		throw new BadMethodCallException("this test uses EventBase::loop()");
	}
}

include "helper/server.inc";

server("proxy.inc", function($port) {
	$evbase = new EventBase;
	$client = new http\Client;
	$client->configure([
			"use_eventloop" => new UserHandler($client, $evbase)
	]);
	$client->enqueue(new http\Client\Request("GET", "http://localhost:$port/"), function($r) {
		var_dump($r->getResponseCode());
	});
	$evbase->loop();
});

?>
===DONE===
--EXPECTREGEX--
Test
T*[ST]+U+T*int\(200\)
===DONE===