如何解决Multi collectItems 如何提前终止并返回收集的项目
在我的 quarkus 服务中,我正在构建 a custom accumulator 以使用 Multi
。流可能是无限的,我想知道如何在积累了足够的数据后提前终止并收集结果?
以下是我的原型:
Multi<Data> sortedStream = getStream();
return this.sortedStream.collectItems().in(
LinkedList::new,new BiConsumer<LinkedList<Coverage>,Data>() {
@Override
public void accept(LinkedList<Coverage> coverages,Data incoming) {
if (coverages.isEmpty()) {
coverages.add(new Coverage(incoming));
return;
}
if (enough(coverages)) {
// Question: How to early terminate and collect coverage downstream?
}
Coverage last = coverages.getLast();
if (worthAdd(last,incoming)) {
coverages.add(new Coverage(incoming));
} else {
return;
}
}
}
)
解决方法
根据官方团队 (https://github.com/smallrye/smallrye-mutiny/issues/501) 的说法,collect
收集所有物品,直到终端事件。
我设法调整了我的算法,想出了一种方法来检查上游的每个项目并使用 multi.select().first
API 提前终止。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。