2017-01-02 47 views
0

我觀察到的是這樣的:發送數據到可觀察到在RX的Android

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

我可以把網址給我觀察到,每次我想訂閱嗎?

回答

0

如果您將此調用包裝在方法中,您將能夠將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