49796.php

49796.php

<?php

use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Component\HttpClient\MockHttpClient;
use Symfony\Component\HttpClient\Response\MockResponse;
use Symfony\Component\HttpClient\TraceableHttpClient;

final class Foo
{
    public function __construct(private readonly HttpClientInterface $httpClient)
    {
    }

    public function bar(): \Generator
    {
        $contentGenerator = $this->streamContent();
        while ($contentGenerator->valid()) {
            $content = $contentGenerator->current();

            if (yield $content) {
                $contentGenerator->send(true);

                continue;
            }

            $contentGenerator->send(false);
        }
    }

    private function streamContent(): \Generator
    {
        $response = $this->httpClient->request('GET', 'https://symfony.com');

        foreach ($this->httpClient->stream($response) as $response => $chunk) {
            if (yield $chunk->getContent()) {
                $response->cancel();

                break;
            }
        }
    }
}

$mockResponse = new MockResponse([
    'fo',
    'o',
    'ba',
    'r',
]);
$httpClient = new TraceableHttpClient(new MockHttpClient($mockResponse));
$generator = (new Foo($httpClient))->bar();
while ($generator->valid()) {
    $content = $generator->current();
    if ('ba' === $content) {
        $generator->send(true);

        continue;
    }

    $generator->send(false);
}

dump($mockResponse->getInfo('canceled')); // false
dump($httpClient->getTracedRequests()[0]['info']['canceled']); // false