async def _create_content_stream(self, binary_data: bytes):
        """Create an async generator for binary content."""
        yield binary_data
Create an async generator for binary content.
backend/airweave/platform/sources/outlook_mail.py