Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
30 changed files
with
2,762 additions
and
1,965 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,79 @@ | ||
| <?php | ||
|
|
||
|
|
||
| use Amp\File\File; | ||
| use Amp\File\StatCache; | ||
| use Amp\Http\Client\HttpClientBuilder; | ||
| use Amp\Http\Client\HttpException; | ||
| use Amp\Http\Client\Request; | ||
| use Amp\Http\Client\Response; | ||
| use Amp\Loop; | ||
| use function Amp\getCurrentTime; | ||
|
|
||
| require __DIR__ . '/../.helper/functions.php'; | ||
|
|
||
| // https://stackoverflow.com/a/2510540/2373138 | ||
| function formatBytes(int $size, int $precision = 2) | ||
| { | ||
| $base = \log($size, 1024); | ||
| $suffixes = ['bytes', 'kB', 'MB', 'GB', 'TB']; | ||
|
|
||
| return \round(1024 ** ($base - \floor($base)), $precision) . ' ' . $suffixes[(int) $base]; | ||
| } | ||
|
|
||
| function fetch(string $uri, array $protocolVersions): \Generator | ||
| { | ||
| try { | ||
| $start = getCurrentTime(); | ||
|
|
||
| // Instantiate the HTTP client | ||
| $client = HttpClientBuilder::buildDefault(); | ||
|
|
||
| $request = new Request($uri); | ||
| $request->setProtocolVersions($protocolVersions); | ||
| $request->setBodySizeLimit(16 * 1024 * 1024); // 128 MB | ||
| $request->setTransferTimeout(120 * 1000); // 120 seconds | ||
|
|
||
| /** @var Response $response */ | ||
| $response = yield $client->request($request); | ||
|
|
||
| print "\n"; | ||
|
|
||
| $path = \tempnam(\sys_get_temp_dir(), "artax-streaming-"); | ||
|
|
||
| /** @var File $file */ | ||
| $file = yield Amp\File\open($path, "w"); | ||
|
|
||
| $bytes = 0; | ||
|
|
||
| while (null !== $chunk = yield $response->getBody()->read()) { | ||
| yield $file->write($chunk); | ||
| $bytes += \strlen($chunk); | ||
|
|
||
| print "\r" . formatBytes($bytes) . ' '; // blanks to remove previous output | ||
| } | ||
|
|
||
| yield $file->close(); | ||
|
|
||
| print \sprintf( | ||
| "\rDone in %.2f seconds with peak memory usage of %.2fMB.\n", | ||
| (getCurrentTime() - $start) / 1000, | ||
| (float) \memory_get_peak_usage(true) / 1024 / 1024 | ||
| ); | ||
|
|
||
| // We need to clear the stat cache, as we have just written to the file | ||
| StatCache::clear($path); | ||
| $size = yield Amp\File\size($path); | ||
|
|
||
| print \sprintf("%s has a size of %.2fMB\r\n", $path, (float) $size / 1024 / 1024); | ||
| } catch (HttpException $error) { | ||
| // If something goes wrong Amp will throw the exception where the promise was yielded. | ||
| // The HttpClient::request() method itself will never throw directly, but returns a promise. | ||
| echo $error; | ||
| } | ||
| } | ||
|
|
||
| Loop::run(static function () { | ||
| yield from fetch('http://1153288396.rsc.cdn77.org//img/cdn77-test-14mb.jpg', ['1.1']); | ||
| yield from fetch('https://1906714720.rsc.cdn77.org/img/cdn77-test-14mb.jpg', ['2']); | ||
| }); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| <?php | ||
|
|
||
| namespace Amp\Http\Client\Connection; | ||
|
|
||
| use Amp\CancellationToken; | ||
| use Amp\Http\Client\Request; | ||
| use Amp\Promise; | ||
|
|
||
| interface ConnectionFactory | ||
| { | ||
| /** | ||
| * During connection establishment, the factory must call the {@see EventListener::startConnectionCreation()}, | ||
| * {@see EventListener::startTlsNegotiation()}, {@see EventListener::completeTlsNegotiation()}, and | ||
| * {@see EventListener::completeConnectionCreation()} on all event listeners registered on the given request in the | ||
| * order defined by {@see Request::getEventListeners()} as appropriate (TLS events are only invoked if TLS is | ||
| * used). Before calling the next listener, the promise returned from the previous one must resolve successfully. | ||
| * | ||
| * Additionally, the factory may invoke {@see EventListener::startDnsResolution()} and | ||
| * {@see EventListener::completeDnsResolution()}, but is not required to implement such granular events. | ||
| * | ||
| * @param Request $request | ||
| * @param CancellationToken $cancellationToken | ||
| * | ||
| * @return Promise | ||
| */ | ||
| public function create(Request $request, CancellationToken $cancellationToken): Promise; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.