Close a request before its end

[Nek-]

Hello,

I have the following code:

$foo = new class {
  private $response;
  private $buffer = '';
  public function request() {
    $client = (new HttpClientBuilder)->build();
    $request = new Request('https://127.0.0.1/acme', 'GET');
    $request->setInactivityTimeout(60);
    $request->setTransferTimeout(60);
    $request->setTcpConnectTimeout(60);
    $this->response = $client->request($request);
    while (null !== $chunk = $this->response->getBody()->read()) {
        $this->buffer .= $chunk;

        echo "Received: \n$chunk\n";
    }
  }

  public function stop() {
    $this->response->getBody()->close();
  }
}

await([
  async(function () use ($foo) {
      $foo->request();
  }),
  async(function () use($foo) {
    delay(10); // Of course imagine something else here than the delay
    $foo->stop();
  })
]);

Doing this results in the following error:

PHP Fatal error:  Uncaught Amp\Pipeline\DisposedException: The iterator has been disposed in vendor/amphp/pipeline/src/Internal/QueueState.php:185

Is there any best way to stop the connection without getting such an error?

By the way... This exception does not seem possible to be caught.

[Nek-]

I found the solution to my problem. My solution was entirely wrong. I had to go so deep inside the library to find the solution 😱 .

But here it is:

$foo = new class {
  private $response;
  private $buffer = '';
  private $cancel;
  public function request() {
    $client = (new HttpClientBuilder)->build();
    $request = new Request('https://127.0.0.1/acme', 'GET');
    $request->setInactivityTimeout(60);
    $request->setTransferTimeout(60);
    $request->setTcpConnectTimeout(60);
    $this->cancel = new DeferredCancellation();
    $this->response = $client->request($request, $this->cancel->getCancellation());

    try {
      while (null !== $chunk = $this->response->getBody()->read()) {
          $this->buffer .= $chunk;
  
          echo "Received: \n$chunk\n";
      }
    } catch (CancelledException) {
        echo "Cancelled\n";
    }
  }

  public function stop() {
    $this->cancel->cancel();
  }
}

await([
  async(function () use ($foo) {
      $foo->request();
  }),
  async(function () use($foo) {
    delay(10); // Of course imagine something else here than the delay
    $foo->stop();
  })
]);

1. It requires the usage of a Cancellation object.
2. amphp provides tooling for the management and creation of the Cancellation if you use the \Amp\DeferredCancellation
3. You can then use directly ->cancel() on your instance of DeferredCancellation
4. It will trigger a CancelledException that you can catch (see my example)