Real-Time Medical Device Data Stream Processor

Create a TypeScript class that can handle concurrent streaming of medical device telemetry data using RxJS observables. Design a type-safe pipeline that can process ECG, pulse oximetry, and blood pressure readings with less than 50ms latency. Implement error handling for device disconnections, data validation using zod schemas, and automatic rate limiting to prevent overwhelming the system. Include methods for dynamic configuration of data sampling rates and alert thresholds.