Rust Stream Processing Framework