- [ ] 🟨 Add support for async methods in BasePipelineWrapper - [ ] 🟨 Implement async_streaming_generator utility