fix(audit): mirror source if durations are Observable.empty()

spec/operators/audit-spec.ts

@@ -127,6 +127,18 @@ describe('Observable.prototype.audit', () => {
  expectSubscriptions(e1.subscriptions).toBe(e1subs);
  });
 
+ it('should mirror source if durations are Observable.empty()', () => {
+ const e1 = hot('abcdefabcdefabcdefabcdefa|');
+ const e1subs = '^ !';
+ const e2 = Rx.Observable.empty();
+ const expected = 'abcdefabcdefabcdefabcdefa|';
+
+ const result = e1.audit(() => e2);
+
+ expectObservable(result).toBe(expected);
+ expectSubscriptions(e1.subscriptions).toBe(e1subs);
+ });
+
  it('should emit no values if duration is a never', () => {
  const e1 = hot('----abcdefabcdefabcdefabcdefa|');
  const e1subs = '^ !';

src/operator/audit.ts

@@ -85,7 +85,12 @@ class AuditSubscriber<T, R> extends OuterSubscriber<T, R> {
  if (duration === errorObject) {
  this.destination.error(errorObject.e);
  } else {
- this.add(this.throttled = subscribeToResult(this, duration));
+ const innerSubscription = subscribeToResult(this, duration);
+ if (innerSubscription.closed) {
+ this.clearThrottle();
+ } else {
+ this.add(this.throttled = innerSubscription);
+ }
  }
  }
  }