public function concatMap(callable $selector, callable $resultSelector = null): Observable
    {
        return $this->lift(function () use ($selector, $resultSelector) {
            return new ConcatMapOperator(new ObservableFactoryWrapper($selector), $resultSelector);
        });
    }