fDh process_sensor_data(sensors: Stream[Reading]): (Analysis~, Anomaly?, Report)
=
analysis = sensors.analyze_trends();
anomaly = detect_anomalies(analysis)?;
report = generate_quality_report(analysis);
[data_development, realtime];
=>
analysis~.pipe, # Stream to dashboard
anomaly?.maybe, # Optional alerts
report.print # Human-readable report
Data Pipeline with Outcome Guarantees
- Continuous stream processing with backpressure handling
- Optional anomaly detection with explicit handling
- Multiple outcome types in single function
- Real-time performance guarantees