feat(effects): accept ObservableInput as concatLatestFrom argument (#3838)

Author: benlesh

modules/effects/src/concat_latest_from.ts

@@ -1,4 +1,4 @@
-import { Observable, ObservedValueOf, of, OperatorFunction, pipe } from 'rxjs';
+import { Observable, ObservableInput, of, ObservedValueOf, OperatorFunction } from 'rxjs';
 import { concatMap, withLatestFrom } from 'rxjs/operators';
 
 // The array overload is needed first because we want to maintain the proper order in the resulting tuple
@@ -38,24 +38,22 @@ export function concatLatestFrom<T extends Observable<unknown>, V>(
  * ```
  */
 export function concatLatestFrom<
-  T extends Observable<unknown>[] | Observable<unknown>,
+  T extends ObservableInput<unknown>[] | ObservableInput<unknown>,
   V,
   R = [
     V,
-    ...(T extends Observable<unknown>[]
+    ...(T extends ObservableInput<unknown>[]
       ? { [i in keyof T]: ObservedValueOf<T[i]> }
       : [ObservedValueOf<T>])
   ]
 >(observablesFactory: (value: V) => T): OperatorFunction<V, R> {
-  return pipe(
-    concatMap((value) => {
-      const observables = observablesFactory(value);
-      const observablesAsArray = Array.isArray(observables)
-        ? observables
-        : [observables];
-      return of(value).pipe(
-        withLatestFrom(...observablesAsArray)
-      ) as unknown as Observable<R>;
-    })
-  );
+  return concatMap((value) => {
+    const observables = observablesFactory(value);
+    const observablesAsArray = Array.isArray(observables)
+      ? observables
+      : [observables];
+    return of(value).pipe(
+      withLatestFrom(...observablesAsArray)
+    ) as unknown as Observable<R>;
+  })
 }