如何在 RxJava 2 中访问和增加“rx2.buffer

本文介绍了如何在 RxJava 2 中访问和增加“rx2.buffer-size"?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

在 reactivex.io/RxJava/javadoc/io/reactx/Observable 声明:

默认情况下，Observable 的操作符以 128 个元素的缓冲区大小运行(参见 Flowable.bufferSize()，可以通过系统参数 rx2.buffer-size 全局覆盖.

The Observable's operators, by default, run with a buffer size of 128 elements (see Flowable.bufferSize(), that can be overridden globally via the system parameter rx2.buffer-size.

我的问题是，如何访问和设置 rx2.buffer-size?如果我这样做:

My question is, how can I access and set rx2.buffer-size? If I do:

import io.reactivex.Completable; import io.reactivex.Flowable; import io.reactivex.Observable; import io.reactivex.Scheduler; import io.reactivex.Single; import io.reactivex.disposables.CompositeDisposable; import io.reactivex.schedulers.Schedulers; import io.reactivex.subjects.BehaviorSubject; import io.reactivex.subjects.PublishSubject; import io.reactivex.subjects.Subject; import io.reactivex.*;

...后跟:

Integer bufferSize = rx2.buffer-size;

Studio 通知我:

I am informed by Studio that:

• 未使用的导入语句(用于import io.reactivex.*;)
• 无法解析符号rx2"
• 无法解析符号大小"

如何覆盖系统参数 rx2.buffer-size?

我的项目正在使用

io.reactivex.rxjava2/rxandroid/2.0.1 io.reactivex.rxjava2/rxjava/2.1.11

推荐答案

尝试:

Integer bufferSize = Integer.parseInt(System.getProperty("rx2.buffer-size"))

设置新值:

System.setProperty("rx2.buffer-size", 2048)