public function __invoke() : void { if ($this->started) { return; } $this->started = true; $this->drain(); }