java - RxJava2 窗口,带指示器的缓冲区
问题描述
[ "start-a", "during-a", "end-a", "start-b", "end-b", "start-c", "something-c", "something-more-c", "end-c"]
使用像上层数组这样的字符串流试图分离start-* ~ end-*
结果下的元素。
["start-a", "during-a", "end-a"]
["start-b", "end-b"]
["start-c", "something-c", "end-c"]
我正在尝试使用窗口运算符
@CheckReturnValue
@BackpressureSupport(BackpressureKind.ERROR)
@SchedulerSupport(SchedulerSupport.NONE)
public final <U, V> Flowable<Flowable<T>> window(
Publisher<U> openingIndicator,
Function<? super U, ? extends Publisher<V>> closingIndicator) {
return window(openingIndicator, closingIndicator, bufferSize());
}
有没有使用窗口操作符(openingIndicator、closeingIndicator)的例子?
解决方案
推荐阅读
- pine-script - 如何在达到目标或止损或条件时退出交易视图中的策略
- ruby-on-rails - 当我使用 Friendly_id gem 时未定义的“id”
- python - 将硒响应传递给回调(SCRAPY)
- java - 使用 do-while 循环将用户输入添加到 ArrayList
- bash - 如何使用 Bash 在 Azure DevOps 中设置构建变量?
- css - css - 并排绘制 2 个正方形,每个正方形的中心都有一个圆圈
- java - 使用 Apache Commons Math 求解具有无限数量解的非平方线性方程
- eclipse - Eclipse 为不存在的用户安装
- rxjs - RxJS 对元素一一应用更改
- swift - Swift - 将参数传递给 Web 服务