Functional streaming library for Scala providing purely functional, composable, and efficient stream processing.