2017-06-30 6 views
1

私はいいえタイプ変数Rのインスタンスが存在するため、ObservableはObservableに準拠していますか?

Observable.from(imagesMulty).map(image -> printImage(image)).subscribe(); 
public void printImage(Image image) 
    { 
Subscription addImage; 


addImage = retrofit.create(Restapi.class).addImage(image) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Subscriber<Response<SlideResponse>>() { 
        @Override 
        public final void onCompleted() { 
         dismissProgress(); 

       } 

       @Override 
       public final void onError(Throwable e) { 

        e.printStackTrace(); 
        dismissProgress(); 

       } 

       @Override 
       public void onNext(Response<SlideResponse> apiResponse) { 
        dismissProgress(); 
        if (apiResponse.code() == 201) { 


        } 

       } 


      }); 
    subscriptions.add(addSlide); 
    } 

が示すタイプのインスタンス変数Rが、私はこのエラーでいただきました!知っているとどのようにresolve.MyするObservable.Letするように観察可能準拠して存在していないその呼び出そうとRxのandroid.Whenに新しいです要件は、APIを次々と呼び出すことです。

コンパイル "com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0"も追加しようとしましたが、まだエラーがあります。

答えて

0

この例を試すことができます。これはあなたの問題を解決するのに役立ちます

0

RxJava2は、Observable.from()機能を使用することを許可していません。使用はcom.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0RxJavaを使用しています。 (バージョン競合)

ベスト実装が

...あなたは map演算子を使用して後付けのものを組み合わせまたはZIPにしたい場合は、 zipconcatまたは combinelatestを使用することを検討して

Disposable subscription; 
subscription = Observable.just(imagesMulty) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Consumer<String>() { 
       @Override 
       public void accept(@NonNull String s) throws Exception { 
        // do retrofit stuff 
       } 
      }, new Consumer<Throwable>() { 
       @Override 
       public void accept(@NonNull Throwable throwable) throws Exception { 
        throwable.printStackTrace(); 
       } 
      }); 
subscription.dispose(); // Call in onDestroy() or onPause() 

Rxjava2で)このようにする必要があります

関連する問題