java - 从流中读取和累积记录的反应式(java)方式
问题描述
这里是反应式编程的新手。
在Multi转换中,我需要为几次迭代累积字节,检查传入的字节,当我遇到特定的字节模式时,我会发布整个累积的 byteArray 以供进一步使用。
似乎是一个简单的要求,但我被卡住了。
伪 Kotlin 代码:
val array = listOf<ByteArray>(....)
Multi.createFrom().items(array)
.onItem.transform { oneByteArray: ByteArray ->
if (oneByteArray.indexOf(0x0d) == -1) {
// somehow accumulate oneByteArray somewhere (1)
// do not publish anything downstream (2)
} else {
// publish accumulated byteArrays as one large byteArray
}
}
我坚持(1)和(2)。暂时停止下游发布(当我正在寻找特定字节时)的机制是什么?
解决方案
推荐阅读
- python - 根据范围合并数据框
- javascript - 在 vue ionic 中生成的 pdf 上没有实现 css 和 html 标签
- haskell - 我可以在不重新编译的情况下生成“完全公开”和“正常”版本的 Haddock 文档吗?
- java - Okhttp3 - 如何在 Okhttp3 客户端中定义特定请求
- julia - `CategoricalArray` 构造函数和 `categorical` 函数之间的区别
- python - 特殊行中的 setRowHeight pandastable
- python - 防止 jupyter notebook 在打开时运行所有单元格
- google-compute-engine - TPU 训练在某些指标上失败,在 CPU 上成功
- c++ - 如果主机定义具有构造函数,则从 DLL 返回的结构读取垃圾
- javascript - module.exports 在依赖项(导入)上不可用