fix(until): Add defaultIfEmpty.

cartant · Jan 9, 2019 · 8c68457 · 8c68457
1 parent 046953f
commit 8c68457
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/source/rules/rxjsNoUnsafeTakeuntilRule.ts b/source/rules/rxjsNoUnsafeTakeuntilRule.ts
@@ -40,6 +40,7 @@ class Walker extends Lint.ProgramAwareRuleWalker {
 
     private allow: string[] = [
         "count",
+        "defaultIfEmpty",
         "endWith",
         "every",
         "finalize",

diff --git a/test/v6/fixtures/no-unsafe-takeuntil/allow-default/fixture.ts.lint b/test/v6/fixtures/no-unsafe-takeuntil/allow-default/fixture.ts.lint
@@ -1,6 +1,7 @@
 import { of } from "rxjs";
 import {
     count,
+    defaultIfEmpty,
     endWith,
     every,
     finalize,
@@ -28,6 +29,7 @@ const b = of("b");
 let r: Observable<any>;
 
 r = a.pipe(takeUntil(b), count()).subscribe();
+r = a.pipe(takeUntil(b), defaultIfEmpty('empty')).subscribe();
 r = a.pipe(takeUntil(b), endWith("z")).subscribe();
 r = a.pipe(takeUntil(b), every(value => value !== "z")).subscribe();
 r = a.pipe(takeUntil(b), finalize(() => {})).subscribe();