发送数据到可观察到在RX的Android

发送数据到可观察到在RX的Android

问题描述:

我观察到的是这样的:发送数据到可观察到在RX的Android

final Observable<Model> ModelObservable=Observable.create(new Observable.OnSubscribe<Model>() { 
     @Override 
     public void call(Subscriber<? super Model> subscriber) { 
      return fetchFrom(url); 
     } 
    });  

我可以把网址给我观察到,每次我想订阅吗?

如果您将此调用包装在方法中,您将能够将URL传递给方法。

private void callWithUrl(final String url) { 
    final Observable<Model> ModelObservable = Observable.create(new Observable.OnSubscribe<Model>() { 
    @Override 
    public void call(Subscriber<? super Model> subscriber) { 
     return fetchFrom(url); 
    } 
    }); 
} 
+0

它被认为是不好的做法使用create(),因为你然后应该提供背压功能。 – FinalFive