Function constructor

packages/core/src/lib/abstract-base.ts:117–154

(config?: BaseConfig)

  // tslint:enable:variable-name

  protected constructor(config?: BaseConfig) {
    super();

    this.config = {...config};

    if (this.config.id !== undefined) {
      if (!isValidId(this.config.id)) {
        throw new TypeError(
          `Invalid id provided, expected a non-empty string, got ${String(this.config.id)}`
        );
      }
      if (Configuration.ENVIRONMENT.checkUniqueId === true) {
        const locationId = getLocationId(this);
        if (
          UniqueIdsAndLocationIdMap[this.config.id] != null &&
          UniqueIdsAndLocationIdMap[this.config.id] !== locationId
        ) {
          throw new TypeError(
            `Duplicate id "${this.config.id}" detected by "checkUniqueId" check, consider assigning a unique id.`
          );
        }
        UniqueIdsAndLocationIdMap[this.config.id] = locationId;
      }
    } else if ((this.config as UnitConfig<any>).persistent === true) {
      throw new TypeError(`An id is required for persistence to work.`);
    }

    if (this.config.replay === false) {
      this.sourceSubject = this.futureSubject;
      (this as any).source = this.future$;
    } else {
      this.sourceSubject = new BehaviorSubject(undefined);
      (this as any).source = this.sourceSubject.asObservable();
    }

    this.setupEvents();
    Object.freeze(this.config);
  }

  /**
   * Creates a new Observable using the default Observable as source.