android - 区分 initial call 和 next emits in flowable

Question

我目前订阅了一个使用 RxJava2 的可流动方法假设我有一个订阅方法。

public Flowable<UploadStatus> getStatusChanges() 

我将首先调用以从数据库加载所有项目状态，因此基本上会在我的回收站 View 上加载所有项目。但是一旦我订阅了，我就会继续从那个可流动的事件中获取事件。我将从确定的项目中获取个别更改，例如更改确定的项目。

我如何区分初始加载中的个别更改？

Answer 1

假设您将结果包装到这样的类中:

class Wrapper {
    public boolean firstLoad;
    public UploadStatus uploadStatus;

    //constructor omitted for brevity 
}

你可以这样做:

getStatusChanges()
    .map(item -> Wrapper(false, item))
    .startWith(Wrapper(true, null)
    .subscribe(result -> {
        if(result.firstLoad) {
            //show spinner
        } else {
            //handle normaly
        }
    })

另一种方法(改编 self 的回答 here )是使用发布。

getStatusChanges().publish(items -> items.first().map(item -> Wrapper(true, item)).concatWith(items.skip(1).map(item -> Wrapper(false, item))))