Composable async generator pipelines (Python) - View it on GitHub