Method handleChangeDetection

libs/template/push/src/lib/push.pipe.ts:181–219

@internal

()

  /** @internal */
  private handleChangeDetection(): Unsubscribable {
    const scope = (this.cdRef as any).context;
    const sub = new Subscription();

    // Subscription can be side-effectful, and we don't want any signal reads which happen in the
    // side effect of the subscription to be tracked by a component's template when that
    // subscription is triggered via the async pipe. So we wrap the subscription in `untracked` to
    // decouple from the current reactive context.
    //
    // `untracked` also prevents signal _writes_ which happen in the subscription side effect from
    // being treated as signal writes during the template evaluation (which throws errors).
    const setRenderedValue = untracked(() =>
      this.templateValues$.subscribe(({ value }) => {
        this.renderedValue = value;
      })
    );
    const render = untracked(() =>
      this.hasInitialValue(this.templateValues$)
        .pipe(
          switchMap((isSync) =>
            this.templateValues$.pipe(
              // skip ticking change detection
              // in case we have an initial value, we don't need to perform cd
              // the variable will be evaluated anyway because of the lifecycle
              skip(isSync ? 1 : 0),
              // onlyValues(),
              this.render(scope),
              tap((v) => {
                this._renderCallback?.next(v);
              })
            )
          )
        )
        .subscribe()
    );
    sub.add(setRenderedValue);
    sub.add(render);
    return sub;
  }

  /** @internal */
  private render<T>(scope: object): OperatorFunction<RxNotification<T>, T> {