如何創建自定義訂閱者？

Question

我想顯示progressDialog，而observable正在下載文件，並且當它完成後要發送文件給訂閱者。

我試圖讓我的自定義用戶從Subscriber延伸例如：

public abstract class MySubscriber<T> extends Subscriber { 
    abstract void onMessage(String message); 
    abstract void onDownloaded(File file); 
} 

，並試圖用它來訂閱： `

MySubscriber mySubscriber = new MySubscriber() { 
      @Override 
      public void onMessage(String message) { 
       progessDialog.setMessage(message); 
      } 

      @Override 
      public void onCompleted() { 

      } 

      @Override 
      public void onError(Throwable e) { 

      } 

      @Override 
      public void onNext(Object o) { 

      } 
     }; 

observable.subscribe(mySubscriber);

觀察到的是：

observable = Observable.create(new Observable.OnSubscribe<Void>() { 
      @Override 
      public void call(Subscriber<Void> subscriber) { 
       //file downloading code... 
       if (subscriber instanceof MySubscriber){ 
       ((MySubscriber) subscriber).onMessage("100%"); 
       ((MySubscriber) subscriber).onDownloaded(file); 
       }else{ 
        Log.e(TAG,"subscriber is not instance of MySubscriber") 
       } 
      } 

而且答案是「用戶不是MySubscriber的實例」

Answer 1

原因subscriber不是MySubscriber類型的，因爲你通過實例由subscribe()在SafeSubscriber最終包裝：

private static <T> Subscription subscribe(Subscriber<? super T> subscriber, Observable<T> observable) { 
    ... 
     if(!(subscriber instanceof SafeSubscriber)) { 
      subscriber = new SafeSubscriber((Subscriber)subscriber); 
     } 
    ... 
    } 
} 

如果你想繼續使用你的方法，你可以投subscriber到SafeSubscriber並調用SafeSubscriber#getActual()就可以得到MySubscriber的實例。

你的情況：

Observable.create(new Observable.OnSubscribe<Void>() { 
    @Override 
    public void call(Subscriber<? super Void> subscriber) { 
     Subscriber yourSubscriber = ((SafeSubscriber) subscriber).getActual(); 
     ((MySubscriber) yourSubscriber).onMessage("100%"); 
     ((MySubscriber) yourSubscriber).onDownloaded(file); 
    } 
});