区分流动中的初始调用和下一个发射

Question

public Flowable<UploadStatus> getStatusChanges() 

如何将单个更改与初始加载不同？

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
        }
    })

另一种方法（根据我这里的回答改编）是使用Publish。

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