-->

如何访问和RxJava 2增加“rx2.buffer大小”?(How to access and i

2019-10-29 02:29发布

在http://reactivex.io/RxJava/javadoc/io/reactivex/Observable中指出:

可观察的操作员,通过默认,具有128个元素(的缓冲区大小运行见Flowable.bufferSize(),可以全局通过系统参数rx2.buffer尺寸来覆盖。

我的问题是,我怎么能访问和设置rx2.buffer-size ? 如果我做:

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获悉:

  • 未使用的导入语句( import io.reactivex.*;
  • 无法解析符号“RX2”
  • 无法解析符号“大小”

我怎样才能覆盖系统参数rx2.buffer-size

我的项目是使用

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

Answer 1:

尝试:

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

要设置一个新值:

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


文章来源: How to access and increase 'rx2.buffer-size' in RxJava 2?