@internal
()
| 539 | |
| 540 | /** @internal */ |
| 541 | ngOnInit() { |
| 542 | this.subscription.add( |
| 543 | this.templateManager |
| 544 | .render(merge(this.values$, this.templateNotification$)) |
| 545 | .subscribe((n) => { |
| 546 | this.rendered$.next(n); |
| 547 | this._renderObserver?.next(n); |
| 548 | }), |
| 549 | ); |
| 550 | this.subscription.add( |
| 551 | merge( |
| 552 | this.contextTrigger || NEVER, |
| 553 | this.nextTrigger?.pipe(map(() => RxNotificationKind.Next)) || NEVER, |
| 554 | this.suspenseTrigger?.pipe(map(() => RxNotificationKind.Suspense)) || |
| 555 | NEVER, |
| 556 | this.completeTrigger?.pipe(map(() => RxNotificationKind.Complete)) || |
| 557 | NEVER, |
| 558 | this.errorTrigger?.pipe(map(() => RxNotificationKind.Error)) || NEVER, |
| 559 | ) |
| 560 | .pipe(filter((v) => !!v)) |
| 561 | .subscribe((t) => this.triggerHandler.next(t)), |
| 562 | ); |
| 563 | } |
| 564 | |
| 565 | /** @internal */ |
| 566 | ngOnChanges(changes: SimpleChanges) { |