如何创建自定义订阅服务器？

NickUnuchek 发表于 Dev

尼克·尤努切克

我要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的实例”

AndroidEx

之所以subscriber没有这种类型，MySubscriber是因为您传递的实例最终被subscribe()in包装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);
    }
});

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。