refactor(concatIfEmpty): Rename.

Author: cartant

source/operators/defaultObservableIfEmpty-spec.ts renamed to source/operators/concatIfEmpty-spec.ts

@@ -4,16 +4,10 @@
  */
 /*tslint:disable:no-unused-expression*/
 
-import { expect } from "chai";
 import { marbles } from "rxjs-marbles";
-import { defaultObservableIfEmpty, switchIfEmpty } from "./defaultObservableIfEmpty";
+import { concatIfEmpty } from "./concatIfEmpty";
 
-describe("defaultObservableIfEmpty", () => {
-
-    it("should export an alias", () => {
-
-        expect(switchIfEmpty).to.equal(defaultObservableIfEmpty);
-    });
+describe("concatIfEmpty", () => {
 
     it("should return the source if not empty", marbles((m) => {
 
@@ -22,7 +16,7 @@ describe("defaultObservableIfEmpty", () => {
         const def =      m.cold("--d--|");
         const expected = m.cold("--a--b--c--|");
 
-        const destination = source.pipe(defaultObservableIfEmpty(def));
+        const destination = source.pipe(concatIfEmpty(def));
         m.expect(destination).toBeObservable(expected);
         m.expect(source).toHaveSubscriptions(subs);
         m.expect(def).toHaveSubscriptions([]);
@@ -36,7 +30,7 @@ describe("defaultObservableIfEmpty", () => {
         const defSubs =         "----^----!";
         const expected = m.cold("------d--|");
 
-        const destination = source.pipe(defaultObservableIfEmpty(def));
+        const destination = source.pipe(concatIfEmpty(def));
         m.expect(destination).toBeObservable(expected);
         m.expect(source).toHaveSubscriptions(sourceSubs);
         m.expect(def).toHaveSubscriptions(defSubs);

source/operators/concatIfEmpty.ts

@@ -0,0 +1,22 @@
+/**
+ * @license Use of this source code is governed by an MIT-style license that
+ * can be found in the LICENSE file at https://github.com/cartant/rxjs-etc
+ */
+
+import { EMPTY, merge, Observable, OperatorFunction } from "rxjs";
+import { isEmpty, mergeMap, publish } from "rxjs/operators";
+
+export function concatIfEmpty<T, D = T>(
+    observable: Observable<D>
+): OperatorFunction<T, D | T> {
+
+    return source => source.pipe(
+        publish(sharedSource => merge(
+            sharedSource,
+            sharedSource.pipe(
+                isEmpty(),
+                mergeMap(empty => empty ? observable : EMPTY)
+            )
+        ))
+    );
+}

source/operators/defaultObservableIfEmpty.ts

@@ -3,22 +3,10 @@
  * can be found in the LICENSE file at https://github.com/cartant/rxjs-etc
  */
 
-import { EMPTY, merge, Observable, OperatorFunction } from "rxjs";
-import { isEmpty, mergeMap, publish } from "rxjs/operators";
+import { concatIfEmpty } from "./concatIfEmpty";
 
-export function defaultObservableIfEmpty<T, D = T>(
-    defaultObservable: Observable<D>
-): OperatorFunction<T, D | T> {
+/** @deprecated Renamed to concatIfEmpty */
+export const defaultObservableIfEmpty = concatIfEmpty;
 
-    return (source: Observable<T>) => source.pipe(
-        publish(sharedSource => merge(
-            sharedSource,
-            sharedSource.pipe(
-                isEmpty(),
-                mergeMap((b: boolean) => b ? defaultObservable : EMPTY)
-            )
-        ))
-    );
-}
-
-export const switchIfEmpty = defaultObservableIfEmpty;
+/** @deprecated Renamed to concatIfEmpty */
+export const switchIfEmpty = concatIfEmpty;

source/operators/index.ts

@@ -4,6 +4,7 @@
  */
 
 export * from "./bufferRecent";
+export * from "./concatIfEmpty";
 export * from "./debounceAfter";
 export * from "./debounceTimeSubsequent";
 export * from "./deferFinalize";