src/Pipe/ReadablePipe.php
private function free()
    {
        $this->readable = false;

        $this->poll->free();

        while (!$this->queue->isEmpty()) {
            /** @var \Icicle\Awaitable\Delayed $delayed */
            $delayed = $this->queue->shift();
            $delayed->resolve();
        }
    }
private function free()
    {
        $this->readable = false;

        $this->poll->free();

        while (!$this->queue->isEmpty()) {
            /** @var \Icicle\Awaitable\Delayed $delayed */
            $delayed = $this->queue->shift();
            $delayed->resolve();
        }
    }
Frees all resources used by the writable stream.