我正在尝试定期(每150毫秒)发出事件，即使上游可观察对象会更快地发送事件。但我得到了MissingBackpressureException，即使我调用了onBackpressureBlock()代码:SerializedSubjectsubject=newSerializedSubject(PublishSubject.create());returnsubject.subscribeOn(Schedulers.computation()).doOnSubscribe(()->{NetworkRequestsManager.instance().queryQuotations(pr

来自C#，当我使用RX并且存在背压时，项目会不断添加到内部队列，直到应用程序内存不足(据我所知)。在ReactiveX(RXJava)中，他们似乎采取了不同的立场，在背压开始建立时抛出异常。这意味着我必须使用类似onBackpressureBuffer()的东西并在通话中subscribe()传入Subscriber它向上游提出请求以释放压力。也许是因为我对此使用了RX.NET方法，但对我来说这似乎是精神上的。首先，我是否理解正确？其次，我是否可以“禁用”此功能，以便它的行为方式与RX.NET相同，因为我不想使我的subscribe()复杂化。通过必须检查我是否已经实现了这些背压运算符

我刚开始接触RxJava/RxAndroid，但在理解如何正确处理背压方面遇到了一些问题。我有一个可观察到的文件扫描器，它可以扫描目录并发出文件。应尽快处理这些文件，不要跳过任何文件。所以管道看起来像这样:Observable->Filter{checkiffileisoftype.xyz}不幸的是，我收到了rx.exceptions.MissingBackpressureException错误。所以我阅读了有关背压的信息，如果我理解正确的话，无损选项只是缓冲区和窗口。我试过了onBackpressureBuffer(),buffer()andwindow().虽然所有onBackpr