我正在尝试订阅salesforce频道，我能够从该频道获得消息。但问题是我一个接一个地收到消息，预期的接收方式是当批量消息发布到通道时。需要在订阅服务器中整体获取消息。
比如说，如果我发布500条消息，我需要在订阅服务器上获得全部500条消息。但我收到了一个又一个的信息。
我正在使用以下代码

async with  client:
    for topic in get_topics(system='salesforce'):
        await client.subscribe(topic)
    async for message in client:
        messages = message

上面的代码在异步函数中调用
我不确定这是一个错误从图书馆或我遵循的方法是错误的
请告诉我有什么问题。