给定一个无限的对象流,其中每个对象都有一个ID,那么我如何使用通量来创建一个按ID属性分组的更新缓冲列表(保持最后发出的值)?V=2)] --- buffer -> I want to subscribe with a list of [Obj(ID=B, V=1)]
像下面这样的东西将是完美的,但它似乎等待我的测试中的流量结束,而不是缓冲。.flatMap(GroupedFlux:
在Gatling报告的静力学部分,测试是根据路径分组的。但是,在我们的示例中,API URI +路径是相同的,函数流将根据标头值进行区分,请求方法是POST。因此,在这种情况下,即使我测试了四种不同的场景/流,所有的测试都将被分组为一个,因为路径是相同的。是否有任何选项可供我们根据场景/其他情况对统计部分进行分组</e