public function fail(\Throwable $exception)
    {
        if (null === $this->observable) {
            return;
        }

        $this->observable = null;
        $this->failed = true;
        $this->delayed->reject($exception);
    }
public function fail(\Throwable $exception)
    {
        if (null === $this->observable) {
            return;
        }

        $this->observable = null;
        $this->failed = true;
        $this->delayed->reject($exception);
    }
public function fail ( \ Throwable $ exception ) { if ( null === $ this -> observable ) { return ; } $ this -> observable = null ; $ this -> failed = true ; $ this -> delayed -> reject ( $ exception ) ; }
Marks the observable as complete with the given error.

@param \Throwable $exception
Marks the observable as complete with the given error .