Real-Time Medical Device Data Stream Processor

Create a scalable RxJS-based stream processing system for ingesting continuous medical device telemetry (heart rate, blood oxygen, temperature) with sub-100ms latency. Implement complex event processing to detect anomalies, generate immediate alerts for critical threshold breaches, and maintain a rolling 5-minute diagnostic window. The solution must be HIPAA compliant, support multiple device protocols, and provide a reactive backpressure mechanism to prevent data loss during high-load scenarios.