async def stream_encoder(
    payload: t.AsyncGenerator[str, None],
) -> t.AsyncGenerator[bytes, None]:
    """
    Extract Data from a AsyncGenerator[str, None]
    """
    async for p in payload:
        yield p.encode("utf-8")
Extract Data from a AsyncGenerator[str, None]
src/bentoml/_internal/server/runner_app.py