public function complete($value = null)
    {
        if (null !== $this->started) {
            $this->started->reject(new CompletedError());
        }

        $this->delayed->resolve($value);
    }
public function complete($value = null)
    {
        if (null !== $this->started) {
            $this->started->reject(new CompletedError());
        }

        $this->delayed->resolve($value);
    }
public function complete ( $ value = null ) { if ( null !== $ this -> started ) { $ this -> started -> reject ( new CompletedError ( ) ) ; } $ this -> delayed -> resolve ( $ value ) ; }
Completes the observable with the given value.

@param mixed $value
Completes the observable with the given value .