如何在 RxJava 2 中访问和增加“rx2.buffer-size"?

问题描述

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

默认情况下，Observable 的操作符以 128 个元素的缓冲区大小运行(参见 Flowable.bufferSize()，可以通过系统参数 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)

这篇关于如何在 RxJava 2 中访问和增加“rx2.buffer-size"?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！