在RxJava中使用多個回調的單個操作

Question

如何在RxJava中暴露多個回調的單個操作（例如START帶有一些參數，PROGRESS多次使用其他參數調用，END使用其他參數）？

我想使用包含一個可觀察的各種回調以及任何可觀察到的那些的簽約觸發與其他綁定在相同的底層操作的操作開始時的包裝對象

編輯：一個例子回調接口爲下載操作

interface Callback { 
    void onDownloadStarted(long contentLength, String mimeType, String nameHint); 
    void onDownloadProgress(long downloadedBytes); 
    void onDownloadCompleted(File file); 
} 

Answer 1

你可以把你的操作爲Observable<Status>其中

public static class Info { 
    public final long contentLength; 
    public final String mimeType; 
    public final String nameHint; 
    public Info(long contentLength, String mimeType, String nameHint) { 
     this.contentLength = contentLength; 
     this.mimeType = mimeType; 
     this.nameHint = nameHint; 
    } 
} 
public static class Status { 
    public final Info info; 
    public final long downloadProgress; //in bytes 
    public final Optional<File> file; 
    public Status(Info info, long downloadProgress, Optional<File> file) { 
     this.info = info; 
     this.downloadProgress = downloadProgress; 
     this.file = file; 
    } 
} 

然後，你可以在你的下載運營模式爲：

Observable<Status> download();

你沒有排放，直到下載已經開始和最後的發射有File結果。

你可以使用這樣的：

download() 
    .doOnNext(status -> System.out.println(
     "downloaded " 
     + status.downloadProgress 
     + " bytes of " + status.contentLength)) 
    .last() 
    .doOnNext(status -> System.out.println(
     "downloaded " + status.file.get()) 
    .doOnError(e -> logError(e)) 
    .subscribe();