Curl requests being made, introduction of Response class.

src/CurlHandleMissingException.php

@@ -0,0 +1,4 @@
+<?php
+namespace phpgt\fetch;
+
+class CurlHandleMissingException extends \Exception {}#

src/CurlMultiException.php

@@ -1,4 +1,4 @@
 <?php
 namespace phpgt\fetch;
 
-class CurlMultiHandleException extends \Exception {}#
+class CurlMultiException extends \Exception {}#

src/Http.php

@@ -87,8 +87,10 @@ public function request($input, array $init = []) {
  * completed.
  */
 public function wait() {
-	$this->timer = $this->loop->addTimer(0.1, [$this->requestResolver, "tick"]);
-	$this->loop->run($this->timer);
+	$this->timer = $this->loop->addPeriodicTimer(
+		0.1, [$this->requestResolver, "tick"]
+	);
+	$this->loop->run();
 }
 
 /**

src/Request.php

@@ -127,6 +127,15 @@ public function getCurlHandle() {
 	return $this->curl;
 }
 
+public function getResponseCode():int {
+	return (int)$this->curl->getInfo(CURLINFO_HTTP_CODE);
+}
+
+public function getResponse() {
+	$response = new Response();
+	die("NOT YET IMPLEMENTED");
+}
+
 private function curlInit($options = []) {
 	$defaultOptions = [];
 
@@ -154,6 +163,11 @@ private function curlInit($options = []) {
 	}
 
 	$options = array_merge($defaultOptions, $options);
+
+// The returntransfer option MUST be set, otherwise the promise resolution
+// callbacks will not be able to get the content of the HTTP requests.
+	$options[CURLOPT_RETURNTRANSFER] = true;
+
 	$this->curl->setOptArray($options);
 }
 

src/RequestResolver.php

@@ -16,7 +16,7 @@ class RequestResolver {
 private $requestArray = [];
 private $deferredArray = [];
 private $index;
-private $runningStatus = null;
+private $openConnectionCount = null;
 
 public function __construct(
 string $curlMultiClass = "\PHPCurl\CurlWrapper\CurlMulti") {
@@ -34,34 +34,68 @@ public function add(Request $request, Deferred $deferred) {
  * as requests complete.
  */
 public function tick() {
-	if(is_null($this->runningStatus)) {
+	if(is_null($this->openConnectionCount)) {
 		$this->start();
 	}
 
-	while(false !== ($message = $this->curlMulti->infoRead($messageCount))) {
-		var_dump($message);
+	do {
+		$info = $this->curlMulti->infoRead($messagesInQueue);
+
+		if($info === false) {
+			break;
+		}
+
+		$request = $this->matchRequest($info["handle"]);
+		if($request->getResponseCode() === 200) {
+			$requestIndex = array_search($request, $this->requestArray);
+			$this->deferredArray[$requestIndex]->resolve(
+				$request->getResponse()
+			);
+		}
+
+	}while($messagesInQueue > 0);
+
+	if($this->openConnectionCount === 0) {
+// $this->stopLoopSomehow() no need for comment - function should explain.
+		die("ALL DONE!");
 	}
 
-	// foreach($this->requestArray as $i => $request) {
-		// $deferred = $this->deferredArray[$i];
-	// }
+// Wait for activity on any of the handles.
+	$this->curlMulti->select();
+
+// Execute the multi handle for processing next tick.
+	$status = $this->curlMulti->exec($this->openConnectionCount);
+	if($status !== CURLM_OK) {
+		throw new CurlMultiException($status);
+	}
 }
 
+/**
+ * Adds each request's curl handle to the multi stack.
+ */
 private function start() {
-// Add curl handles to the curlMulti stack.
 	foreach($this->requestArray as $i => $request) {
 		$successCode = $this->curlMulti->add($request->getCurlHandle());
 
 		if($successCode !== 0) {
 			throw new CurlMultiException($successCode);
 		}
 	}
+}
 
-	$this->runningStatus = null;
+/**
+ * Matches and returns the Request object containing the provided curl handle.
+ *
+ * @return Request
+ */
+private function matchRequest($ch) {
+	foreach($this->requestArray as $request) {
+		if($request->getCurlHandle()->getHandle() === $ch) {
+			return $request;
+		}
+	}
 
-// Execute all curl handles on the curlMulti stack.
-	while(CURLM_CALL_MULTI_PERFORM
-	=== $this->curlMulti->exec($this->runningStatus));
+	throw new CurlHandleMissingException($ch);
 }
 
 }#

src/RequestResolverCurlException.php

@@ -0,0 +1,4 @@
+<?php
+namespace phpgt\fetch;
+
+class RequestResolverCurlException extends \Exception {}#

src/Response.php

@@ -0,0 +1,6 @@
+<?php
+namespace phpgt\fetch;
+
+class Response {
+
+}#