fix: share and connect no longer bundle scheduling code by default (#6873)

resolves #6872

Author: benlesh

src/internal/observable/innerFrom.ts

@@ -1,7 +1,7 @@
 import { isArrayLike } from '../util/isArrayLike';
 import { isPromise } from '../util/isPromise';
 import { Observable } from '../Observable';
-import { ObservableInput, ReadableStreamLike } from '../types';
+import { ObservableInput, ObservedValueOf, ReadableStreamLike } from '../types';
 import { isInteropObservable } from '../util/isInteropObservable';
 import { isAsyncIterable } from '../util/isAsyncIterable';
 import { createInvalidObservableTypeError } from '../util/throwUnobservableError';
@@ -12,6 +12,7 @@ import { isFunction } from '../util/isFunction';
 import { reportUnhandledError } from '../util/reportUnhandledError';
 import { observable as Symbol_observable } from '../symbol/observable';
 
+export function innerFrom<O extends ObservableInput<any>>(input: O): Observable<ObservedValueOf<O>>;
 export function innerFrom<T>(input: ObservableInput<T>): Observable<T> {
  if (input instanceof Observable) {
  return input;

src/internal/operators/connect.ts

@@ -1,7 +1,7 @@
 import { OperatorFunction, ObservableInput, ObservedValueOf, SubjectLike } from '../types';
 import { Observable } from '../Observable';
 import { Subject } from '../Subject';
-import { from } from '../observable/from';
+import { innerFrom } from '../observable/innerFrom';
 import { operate } from '../util/lift';
 import { fromSubscribable } from '../observable/fromSubscribable';
 
@@ -103,7 +103,7 @@ export function connect<T, O extends ObservableInput<unknown>>(
  const { connector } = config;
  return operate((source, subscriber) => {
  const subject = connector();
- from(selector(fromSubscribable(subject))).subscribe(subscriber);
+ innerFrom(selector(fromSubscribable(subject))).subscribe(subscriber);
  subscriber.add(source.subscribe(subject));
  });
 }

src/internal/operators/onErrorResumeNext.ts

@@ -101,7 +101,7 @@ export function onErrorResumeNext<T, A extends readonly unknown[]>(
  if (remaining.length > 0) {
  let nextSource: Observable<A[number]>;
  try {
- nextSource = innerFrom<T | A[number]>(remaining.shift()!);
+ nextSource = innerFrom(remaining.shift()!);
  } catch (err) {
  subscribeNext();
  return;

src/internal/operators/share.ts

@@ -1,5 +1,5 @@
 import { Observable } from '../Observable';
-import { from } from '../observable/from';
+import { innerFrom } from '../observable/innerFrom';
 import { take } from '../operators/take';
 import { Subject } from '../Subject';
 import { SafeSubscriber } from '../Subscriber';
@@ -232,7 +232,7 @@ export function share<T>(options: ShareConfig<T> = {}): MonoTypeOperatorFunction
  dest.complete();
  },
  });
- from(source).subscribe(connection);
+ innerFrom(source).subscribe(connection);
  }
  })(wrapperSource);
  };