Sha256: 84b75f8e29802f8ff5c606c59045a5ad695a65ffcf88f3d38ba40e120f18874c

Contents?: true

Size: 1.61 KB

Versions: 49

Compression:

Stored size: 1.61 KB

Contents

import { Subject } from '../Subject';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
import { Scheduler } from '../Scheduler';
import { TestMessage } from './TestMessage';
import { SubscriptionLog } from './SubscriptionLog';
import { SubscriptionLoggable } from './SubscriptionLoggable';
import { applyMixins } from '../util/applyMixins';

/**
 * We need this JSDoc comment for affecting ESDoc.
 * @ignore
 * @extends {Ignored}
 */
export class HotObservable<T> extends Subject<T> implements SubscriptionLoggable {
  public subscriptions: SubscriptionLog[] = [];
  scheduler: Scheduler;
  logSubscribedFrame: () => number;
  logUnsubscribedFrame: (index: number) => void;

  constructor(public messages: TestMessage[],
              scheduler: Scheduler) {
    super();
    this.scheduler = scheduler;
  }

  /** @deprecated internal use only */ _subscribe(subscriber: Subscriber<any>): Subscription {
    const subject: HotObservable<T> = this;
    const index = subject.logSubscribedFrame();
    subscriber.add(new Subscription(() => {
      subject.logUnsubscribedFrame(index);
    }));
    return super._subscribe(subscriber);
  }

  setup() {
    const subject = this;
    const messagesLength = subject.messages.length;
    /* tslint:disable:no-var-keyword */
    for (var i = 0; i < messagesLength; i++) {
      (() => {
        var message = subject.messages[i];
   /* tslint:enable */
        subject.scheduler.schedule(
          () => { message.notification.observe(subject); },
          message.frame
        );
      })();
    }
  }
}
applyMixins(HotObservable, [SubscriptionLoggable]);

Version data entries

49 entries across 49 versions & 4 rubygems

Version Path
ilog-0.4.1 node_modules/rxjs/src/testing/HotObservable.ts
ilog-0.4.0 node_modules/rxjs/src/testing/HotObservable.ts
ilog-0.3.3 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-18.0.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.21.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.20.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.19.1 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.19.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.18.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.17.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.16.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.15.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.14.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.13.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.12.2 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.12.1 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.12.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.11.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.10.0 node_modules/rxjs/src/testing/HotObservable.ts
govuk_publishing_components-17.9.0 node_modules/rxjs/src/testing/HotObservable.ts