Class RxPush

libs/template/push/src/lib/push.pipe.ts:90–254

 */
@Pipe({ name: 'push', pure: false, standalone: true })
export class RxPush implements PipeTransform, OnDestroy {
  /** @internal */
  private strategyProvider = inject(RxStrategyProvider);
  /** @internal */
  private ngZone = inject(NgZone);
  /**
   * @internal
   * This is typed as `any` because the type cannot be inferred
   * without a class-level generic argument, which was removed to
   * fix https://github.com/rx-angular/rx-angular/pull/684
   */
  private renderedValue: any | null | undefined;
  /** @internal */
  private subscription: Unsubscribable;
  /** @internal */
  private readonly templateObserver = createTemplateNotifier<any>();
  private readonly templateValues$ = this.templateObserver.values$.pipe(
    onlyValues(),
    shareReplay({ bufferSize: 1, refCount: true })
  );
  /** @internal */
  private readonly strategyHandler = strategyHandling(
    this.strategyProvider.primaryStrategy,
    this.strategyProvider.strategies
  );
  /** @internal */
  private patchZone: false | NgZone;
  /** @internal */
  private _renderCallback: NextObserver<any>;

  constructor(private cdRef: ChangeDetectorRef) {}

  transform<U>(
    potentialObservable: null,
    config?: RxStrategyNames | Observable<RxStrategyNames>,
    renderCallback?: NextObserver<U>
  ): null;
  transform<U>(
    potentialObservable: undefined,
    config?: RxStrategyNames | Observable<RxStrategyNames>,
    renderCallback?: NextObserver<U>
  ): undefined;
  transform<U>(
    potentialObservable: ObservableInput<U> | U,
    config?: RxStrategyNames | Observable<RxStrategyNames>,
    renderCallback?: NextObserver<U>
  ): U;
  transform<U>(
    potentialObservable: ObservableInput<U>,
    config?: PushInput<U>
  ): U;
  transform<U>(
    potentialObservable: ObservableInput<U> | U | null | undefined,
    config:
      | PushInput<U>
      | RxStrategyNames
      | Observable<RxStrategyNames>
      | undefined,