rxjs

# RxJS Skill Expert assistance for implementing reactive programming with RxJS in Angular and JavaScript applications. ## Capabilities - Create and compose observables - Apply transformation and filtering operators - Handle errors and retries - Implement multicasting patterns - Manage subscriptions and memory - Integrate with Angular HTTP and forms ## Usage Invoke this skill when you need to: - Handle async data streams - Compose complex data pipelines - Implement real-time features - Manage concurrent requests - Handle WebSocket streams ## Inputs | Parameter | Type | Required | Description | |-----------|------|----------|-------------| | useCase | string | Yes | http, websocket, events, state | | operators | array | No | Specific operators needed | | errorHandling | boolean | No | Include error handling | ### Configuration Example ```json { "useCase": "http", "operators": ["switchMap", "debounceTime", "catchError"], "errorHandling": true } ``` ## Observable Patterns ### HTTP with Operators ```typescript import { Injectable, inject } from '@angular/core'; import { HttpClient } from '@angular/common/http'; import { Observable, Subject, BehaviorSubject, catchError, debounceTime, distinctUntilChanged, switchMap, retry, shareReplay, tap, map, of, } from 'rxjs'; @Injectable({ providedIn: 'root' }) export class SearchService { private http = inject(HttpClient); private searchTerms = new Subject<string>(); // Shared cache with repla...