X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fseekat;a=blobdiff_plain;f=examples%2Famploop.php;h=9afda4c29b20a495fbb8564c5628247275563013;hp=1abbaa11e42d264dacaf4478607f1f6d49ea2bb2;hb=HEAD;hpb=2121556150be871684b5046af7cf250b8219128d

diff --git a/examples/amploop.php b/examples/amploop.php
index 1abbaa1..9afda4c 100755
--- a/examples/amploop.php
+++ b/examples/amploop.php
@@ -6,107 +6,113 @@ require_once __DIR__."/../vendor/autoload.php";
 use seekat\API;
 use Amp\Loop as AmpLoop;
 
-$log = new Monolog\Logger("seekat");
-$log->pushHandler((new Monolog\Handler\StreamHandler(STDERR))->setLevel(Monolog\Logger::INFO));
+$client = new http\Client("curl", "seekat");
+$client->configure([
+	"use_eventloop" => new class($client, AmpLoop::get()) implements http\Client\Curl\User {
 
-$cli = new http\Client("curl", "seekat");
-$cli->configure([
-	"use_eventloop" => new class($cli, AmpLoop::get()) implements http\Client\Curl\User {
+		/**
+		 * Timeout ID
+		 */
+		private ?string $timeout = null;
+		private \Closure $runcb;
 
-	private $driver;
-	private $timeout;
-	private $client;
-	private $runcb;
+		function __construct(private http\Client $client, private AmpLoop\Driver $driver) {
+		}
 
-	function __construct(http\Client $client, AmpLoop\Driver $driver) {
-		$this->client = $client;
-		$this->driver = $driver;
-	}
-	function init($run) {
-		$this->runcb = $run;
-	}
-	function run($socket = null, int $action = null) {
-		if ($socket) {
-			$remaining = ($this->runcb)($this->client, $socket, $action);
-		} else {
-			$remaining = ($this->runcb)($this->client);
+		function init($run) : void {
+			$this->runcb = $run(...);
 		}
 
-		if (!$remaining) {
-			$this->done();
+		/**
+		 * @param resource $socket
+		 */
+		function run($socket = null, int $action = null) : void {
+			if ($socket) {
+				$remaining = ($this->runcb)($this->client, $socket, $action);
+			} else {
+				$remaining = ($this->runcb)($this->client);
+			}
+
+			if (!$remaining) {
+				$this->done();
+			}
 		}
-	}
-	function once() {
-		if (!$this->driver->getInfo()["running"]) {
-			$this->driver->run();
+		function once() : void {
+			if (!$this->driver->getInfo()["running"]) {
+				$this->driver->run();
+			}
 		}
-	}
-	function send() {
-		# unused
-		throw new BadMethodCallException(__FUNCTION__);
-	}
-	function wait(int $timeout_ms = null) {
-		# unused
-		throw new BadMethodCallException(__FUNCTION__);
-	}
-	function timer(int $timeout_ms = null) {
-		if ($this->timeout) {
-			$this->driver->cancel($this->timeout);
+		function send() : never {
+			# unused
+			throw new BadMethodCallException(__FUNCTION__);
+		}
+		function wait(int $timeout_ms = null) : never {
+			# unused
+			throw new BadMethodCallException(__FUNCTION__);
 		}
+		function timer(int $timeout_ms = null) : void {
+			if ($this->timeout) {
+				$this->driver->cancel($this->timeout);
+			}
 
-		$this->timeout = $this->driver->delay($timeout_ms, function() {
-			$this->run();
-		});
-	}
-	function done() {
-		if ($this->timeout) {
-			$this->driver->cancel($this->timeout);
-			$this->timeout = null;
+			$this->timeout = $this->driver->delay($timeout_ms, function() {
+				$this->run();
+			});
 		}
-	}
-	function socket($socket, int $poll) {
-		foreach ((array) $this->driver->getState((string) $socket) as $id) {
-			$this->driver->disable($id);
+		function done() : void {
+			if ($this->timeout) {
+				$this->driver->cancel($this->timeout);
+				$this->timeout = null;
+			}
 		}
-		switch ($poll) {
-		case self::POLL_NONE:
-			break;
-		case self::POLL_IN:
-			$id = $this->driver->onReadable($socket, function($id, $socket) {
-				$this->run($socket, self::POLL_IN);
-			});
-			$this->driver->setState((string) $socket, $id);
-			break;
-		case self::POLL_OUT:
-			$id = $this->driver->onWritable($socket, function($id, $socket) {
-				$this->run($socket, self::POLL_OUT);
-			});
-			$this->driver->setState((string) $socket, $id);
-			break;
-		case self::POLL_INOUT:
-			$id = [
-				$this->driver->onReadable($socket, function($id, $socket) {
+
+		/**
+		 * @param resource $socket
+		 */
+		function socket($socket, int $poll) : void {
+			foreach ((array) $this->driver->getState((string) $socket) as $id) {
+				$this->driver->disable($id);
+			}
+			switch ($poll) {
+			case self::POLL_NONE:
+				break;
+			case self::POLL_IN:
+				$id = $this->driver->onReadable($socket, function($id, $socket) {
 					$this->run($socket, self::POLL_IN);
-				}),
-				$this->driver->onWritable($socket, function($id, $socket) {
+				});
+				$this->driver->setState((string) $socket, $id);
+				break;
+			case self::POLL_OUT:
+				$id = $this->driver->onWritable($socket, function($id, $socket) {
 					$this->run($socket, self::POLL_OUT);
-				})
-			];
-			$this->driver->setState((string) $socket, $id);
-			break;
-		case self::POLL_REMOVE:
-			foreach ((array) $this->driver->getState((string) $socket) as $id) {
-				$this->driver->cancel($id);
+				});
+				$this->driver->setState((string) $socket, $id);
+				break;
+			case self::POLL_INOUT:
+				$id = [
+					$this->driver->onReadable($socket, function($id, $socket) {
+						$this->run($socket, self::POLL_IN);
+					}),
+					$this->driver->onWritable($socket, function($id, $socket) {
+						$this->run($socket, self::POLL_OUT);
+					})
+				];
+				$this->driver->setState((string) $socket, $id);
+				break;
+			case self::POLL_REMOVE:
+				foreach ((array) $this->driver->getState((string) $socket) as $id) {
+					$this->driver->cancel($id);
+				}
+				$this->driver->setState((string) $socket, null);
+				break;
 			}
-			$this->driver->setState((string) $socket, null);
-			break;
 		}
 	}
-}]);
+]);
+
+$future = API\Future\amp();
 
-$api = new API(API\Future\amp(), [
-	"Authorization" => "token ".getenv("GITHUB_TOKEN")
-], null, $cli, $log);
+$api = include "examples.inc";
 
 AmpLoop::run(function() use($api) {
 	list($m6w6, $seekat) = yield [$api->users->m6w6(), $api->repos->m6w6->seekat()];