obs sub

subscribe.ts

  subscribe(observerOrNext?: PartialObserver<T> | ((value: T) => void),
            error?: (error: any) => void,
            complete?: () => void): Subscription {

  const { operator } = this;
  const sink = toSubscriber(observerOrNext, error, complete);

  if (operator) {
    operator.call(sink, this.source);
  } else {
    sink.add(
      this.source || (config.useDeprecatedSynchronousErrorHandling && !sink.syncErrorThrowable) ?
      this._subscribe(sink) :
      this._trySubscribe(sink)
    );
  }

  if (config.useDeprecatedSynchronousErrorHandling) {
    if (sink.syncErrorThrowable) {
      sink.syncErrorThrowable = false;
      if (sink.syncErrorThrown) {
        throw sink.syncErrorValue;
      }
    }
  }

  return sink;
}