async def METHOD_NAME(protocol):
    port = random_port()
    with Flow(protocol=protocol, port=port, cors=True).add(
        uses=MyExecutor,
    ):
        client = Client(port=port, protocol=protocol, asyncio=True)
        i = 10
        async for doc in client.stream_doc(
            on='/hello',
            inputs=MyDocument(text='hello world', number=i),
            return_type=MyDocument,
        ):
            assert doc.text == f'hello world {i}'
            i += 1