Как использовать doOnNext, doOnSubscribe и doOnComplete? - PullRequest
Новая
       6

Как использовать doOnNext, doOnSubscribe и doOnComplete?

0 голосов
/ 06 января 2020

Новичок в разработке RxJava2 / Rx Android и Android, но я довольно хорошо знаком с Java. Тем не менее, я столкнулся с большим препятствием при попытке «оптимизировать» и иметь возможность обновлять пользовательский интерфейс между несколькими вызовами к одному и тому же ресурсу.

Мой код выглядит следующим образом: 

private int batch = 0;
private int totalBatches = 0;
private List<ItemInfo> apiRetItems = new ArrayList<>();
private Observable<ItemInfo[]> apiGetItems(int[] ids) {
    int batchSize = 100;

    return Observable.create(emitter -> {
        int[] idpart = new int[0];

        for(int i = 0; i < ids.length; i += batchSize) {
            batch++;
            idpart = Arrays.copyOfRange(ids, i, Math.min(ids.length, i+batchSize));
            ItemInfo[] items = client.items().get(idpart);
            emitter.onNext(items);
        }
        emitter.onComplete();
    }).doOnSubscribe( __ -> {
        Log.d("GW2DB", "apiGetItems subscribed to with " + ids.length + " ids.");
        totalBatches = (int)Math.ceil(ids.length / batchSize);
        progressbarUpdate(0, totalBatches);
    }).doOnNext(items -> {
        Log.d("GW2DB", batch + " batches of " + totalBatches + " batches completed.");
        progressbarUpdate(batch, totalBatches);
    }).doOnComplete( () -> {
        Log.d("GW2DB", "Fetching items completed!");
        progressbarReset();
    });
}

Если я удаляю doOnSubscribe, doOnNext и doOnComplete, я не получаю ошибок в Android Studio, но если я использую любую из них, я получаю Incompatible types. Required: Observable<[...].ItemInfo[]>. Found: Observable<java.lang.Object>

. используя Rx Android 2.1.1 и Rx Java 2.2.16.

Есть идеи?

1 Ответ

0 голосов
/ 06 января 2020

Поскольку вы добавляете цепочку вызовов методов, компилятор просто не может правильно угадать тип параметра generi c в Observable.create. Вы можете установить его явно, используя Observable.<ItemInfo[]>create(...).

...