2017-01-02 7 views
0

I持ってこのような観測可能:はアンドロイドRXで観察にデータを送信

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

私はそれをサブスクライブしたい私の観察可能な毎回の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

関連する問題