async def stream_decoder(
    iterator: AsyncIterator[bytes],
) -> AsyncGenerator[str, None]:
    """
    Converting bytes to string
    """
    async for data in iterator:
        yield data.decode("utf-8")
Converting bytes to string
tests/unit/test_utils.py