async def client_stream(stream: Stream):
        raise ValueError("This should cause transactions to fail")

    manager = RPCManager()
    manager.register("client_stream", client_stream)
    
    with client.request_stream("client_stream") as stream:
        for i in range(1000000):
            await stream.send(i)  # all items are sent despite the error raised in the remote 
    await stream  #error is raised happens here