加速度计RxJava背压

Question

背压有问题。使用发布主题获取发射时的传感器事件，并需要在事务中订阅主题时将数据保存到数据库。

我一直在尝试使用。窗口（100）操作符，这样每当我连续收到100个传感器事件时，我就可以批量插入，但一次只能收到一个项目。订阅

不希望使用缓冲区运算符删除事件。正确的处理方法是什么？

@Override
public void onSensorChanged(SensorEvent sevent) {

    Sensor sensor = sevent.sensor;

    switch (sensor.getType()) {
        case Sensor.TYPE_ACCELEROMETER:
            sensorEventPublishSubject.onNext(sevent);
            break;
    }
}

sensorEventPublishSubject
            .map(event ->
                    new AccModel(
                            event.values[0],
                            event.values[1],
                            event.values[2],
                            event.accuracy                           
                    )
            )
            .window(100)
            .subscribe(
                    new Action1<Observable<AccModel>>() {
                        @Override
                        public void call(Observable<AccModel> accModelObservable) {
                            //insert in db
                        }
                    }
            );

Answer 1

你有两个选择，这取决于你想对OneError事件做什么。

首先，使用解决方案。window是正确的，只是它发出一个可观察到的，每100个事件你会得到一个可观察到的，当你订阅它时，可观察到的将重播这100个事件。此外，如果发生错误，它也会按顺序重播错误事件（AFAIK）。

如果您不关心序列中的错误事件，那么就有了解决方案。缓冲区（100），您应该在其前面放置OneRorReturn（）或OneRorResumeNext（），用于将OneRor事件转换为onNext。这是因为在出现onError的情况下，buffer操作符会立即传播它，因此会丢失临时缓冲区中的事件(