Как получить доступ и увеличить «rx2.buffer-size» в RxJava 2? - PullRequest
Новая
       55

Как получить доступ и увеличить «rx2.buffer-size» в RxJava 2?

0 голосов
/ 23 октября 2018

В http://reactivex.io/RxJava/javadoc/io/reactivex/Observable указано:

Операторы Observable по умолчанию работают с размером буфера 128 элементов (см. Flowable.bufferSize (), который может быть переопределенглобально через системный параметр rx2.buffer-size.

Мой вопрос, как я могу получить доступ и установить 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

1 Ответ

0 голосов
/ 23 октября 2018

Попробуйте: 

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

Чтобы установить новое значение: 

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