Agent Skills: RxJS Interop

RxJS Interop

Priority: P1 (HIGH)

Principles

• Async to Sync: Use toSignal(observable$, { initialValue: defaultValue }) from @angular/core/rxjs-interop to convert Observables (HTTP, Events) to Signals for template rendering. Call in an injection context (class field or constructor). toSignal auto-unsubscribes on component destroy. Provide initialValue to avoid undefined.
• Sync to Async: Use toObservable(this.query) when you need RxJS operators (debounceTime, switchMap, distinctUntilChanged) on a Signal. Then wrap back with toSignal() if rendering.
• Auto-Unsubscribe: toSignal automatically unsubscribes.
• Cleanup: Use takeUntilDestroyed() for manual subscriptions in injection contexts. For use outside, inject(DestroyRef) and call takeUntilDestroyed(destroyRef).

Guidelines

• HTTP Requests:
  • GET: http.get<User[]>(...).pipe(catchError(() => of([]))) -> toSignal(..., { initialValue: [] }). Use in templates as {{ users() }}.
  • Consider httpResource() for simpler reactive HTTP in newer versions.
  • POST/PUT: Trigger explicit subscribe() or lastValueFrom().
• Race Conditions: Handle async loading states. toSignal requires an initialValue or handles undefined.

Anti-Patterns

• No manual subscribe in templates: Use toSignal() for Observables rendered in templates.
• No BehaviorSubject for state: Replace with signal() + toObservable() for RxJS interop.
• No global takeUntil: Use takeUntilDestroyed() scoped to the injection context. Never use a global Subject with takeUntil — it leaks if Subject is never completed.

References

• Signals vs Observables