test: Response::arrayBuffer

Author: g105b

src/Response.php

@@ -1,14 +1,12 @@
 <?php /** @noinspection PhpUnusedPrivateMethodInspection */
 namespace Gt\Http;
 
-use Gt\Async\Loop;
 use Gt\Curl\CurlInterface;
 use Gt\Http\Header\ResponseHeaders;
 use Gt\Json\JsonObject;
 use Gt\Json\JsonObjectBuilder;
 use Gt\Promise\Deferred;
 use Gt\Promise\Promise;
-use Gt\Promise\PromiseState;
 use Gt\PropFunc\MagicProp;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\UriInterface;
@@ -171,23 +169,6 @@ public function getResponseHeaders():ResponseHeaders {
 		return $this->headers;
 	}
 
-	public function startDeferredResponse(
-		CurlInterface $curl
-	):Deferred {
-		$this->deferred = new Deferred();
-		$this->curl = $curl;
-		return $this->deferred;
-	}
-
-	public function endDeferredResponse(?string $integrity = null):void {
-		$position = $this->stream->tell();
-		$this->stream->rewind();
-		$contents = $this->stream->getContents();
-		$this->stream->seek($position);
-		$this->checkIntegrity($integrity, $contents);
-		$this->deferred->resolve($contents);
-	}
-
 	/**
 	 * Takes the Response's stream and reads it to completion. Returns a Promise which resolves with the result
 	 * as a Gt\Http\ArrayBuffer.
@@ -223,6 +204,8 @@ private function arrayBufferFromResponseText(string $responseText):ArrayBuffer {
 		for($i = 0; $i < $bytes; $i++) {
 			$arrayBuffer->offsetSet($i, ord($responseText[$i]));
 		}
+
+		return $arrayBuffer;
 	}
 
 	/**

test/phpunit/ResponseTest.php

@@ -1,6 +1,7 @@
 <?php
 namespace Gt\Http\Test;
 
+use Gt\Http\ArrayBuffer;
 use Gt\Http\FormData;
 use Gt\Http\Header\ResponseHeaders;
 use Gt\Http\Request;
@@ -104,6 +105,36 @@ public function testReloadWithoutQuery() {
 		self::assertSame($expectedRelativePath, $sut->getHeaderLine("Location"));
 	}
 
+	public function testArrayBuffer():void {
+		$bodyData = random_bytes(1050);
+		$stream = new Stream();
+		$stream->write($bodyData);
+
+		$sut = new Response();
+		$sut = $sut->withBody($stream);
+
+		$actualArrayBuffer = null;
+		$sut->arrayBuffer()->then(function($arrayBuffer) use(&$actualArrayBuffer) {
+			$actualArrayBuffer = $arrayBuffer;
+		});
+
+		self::assertInstanceOf(ArrayBuffer::class, $actualArrayBuffer);
+		self::assertSame(1050, $actualArrayBuffer->byteLength);
+	}
+
+	public function testAsyncArrayBuffer():void {
+		$bodyData = random_bytes(1050);
+		$stream = new Stream();
+		$stream->write($bodyData);
+
+		$sut = new Response();
+		$sut = $sut->withBody($stream);
+
+		$arrayBuffer = $sut->awaitArrayBuffer();
+		self::assertInstanceOf(ArrayBuffer::class, $arrayBuffer);
+		self::assertSame(1050, $arrayBuffer->byteLength);
+	}
+
 	public function testJson():void {
 		$jsonString = json_encode(["name" => "phpgt"]);