RxJava：无法为rx.Observable错误创建呼叫转接

我该怎么办：RxJava：无法为rx.Observable错误创建呼叫转接

public interface ApiInterface { 
    @Multipart 
     @POST("/android/upload/index.php") 
     Observable<Response> postImage(@Part MultipartBody.Part image, @Part("name") RequestBody name); 
}

型号：

public interface Model { 
Observable<Response> postImage(MultipartBody.Part image, RequestBody name); 
}

默认地将Impl：

public class ModelImpl implements Model { 
    ApiModule apiModule = ApiModule.getInstance(); 
@Override 
    public Observable<Response> postImage(MultipartBody.Part image, RequestBody name) { 
     return apiModule.getApi().postImage(image,name); 
    } 
}

主持人：

RxPhoto.requestUri(context, TypeRequest.GALLERY) 
     .flatMap(new Func1<Uri, Observable<Response>>() { 
      @Override 
      public Observable<Response> call(Uri uri) { 

       File file = new File(uri.getPath()); 
       RequestBody reqFile = RequestBody.create(MediaType.parse("image/*"), file); 
       MultipartBody.Part body = MultipartBody.Part.createFormData("upload", file.getName(), reqFile); 
       RequestBody name = RequestBody.create(MediaType.parse("text/plain"), "upload_test"); 
       return model.postImage(body, name); 


      } 
     }).subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Subscriber<Response>() { 

        @Override 
        public void onError(Throwable e) { 

         Log.d(tag, "error:" + e); 

        } 

       });

我有错误：

错误：java.lang.IllegalArgumentException异常：无法创建呼叫转接器rx.Observable 的方法ApiInterface.postImage

UPD：

我改变接口和其他人：

Observable<uploadAnswer> 


    public class uploadAnswer { 

     @SerializedName("success") 
     @Expose 
     private String success; 

     public String getSuccess() { 
      return this.success; 
     } 

    }

之后，我的第一个呃ROR走了，现在我有这个错误：

java.io.FileNotFoundException：/文档/图片：52214：打开失败：ENOENT（没有这样的文件或目录）

怎么办？

UPD2：

我用这个函数来获取文件URI：

public String getRealPathFromURIPath(Uri contentURI) { 
     Cursor cursor = context.getApplicationContext().getContentResolver().query(contentURI, null, null, null, null); 
     if (cursor == null) { 
      return contentURI.getPath(); 
     } else { 
      cursor.moveToFirst(); 
      int idx = cursor.getColumnIndex(MediaStore.Images.ImageColumns.DATA); 
      return cursor.getString(idx); 
     } 
    }

之后，我有这个错误（是意思，我是正确的？）：

错误：android.os.NetworkOnMainThreadException

UPD3：

我的短代码：

RxPhoto.requestUri(context,TypeRequest.GALLERY) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .doOnNext(new Action1<Uri>(){ 

        @Override 
        public void call(Uri uri) { 

         Log.d(tag, "up => " + uri); 

         File file = new File(uri.getPath()); 
         RequestBody reqFile = RequestBody.create(MediaType.parse("image/*"), file); 
         MultipartBody.Part body = MultipartBody.Part.createFormData("upload", file.getName(), reqFile); 
         RequestBody name = RequestBody.create(MediaType.parse("text/plain"), "upload_test"); 

         //model.postImage(body, name); 

         GetDataSubscription = model.postImage(body,name) 
           .subscribeOn(Schedulers.io()) 
           .observeOn(AndroidSchedulers.mainThread()) 
           .subscribe(); 

        } 

       }) 
       .subscribe();

我仍然有错误：

E/AndroidRuntime：致命异常：主要过程：info.masterskaya.om.near，PID： 8348 java.lang.IllegalStateException：在Scheduler.Worker线程上抛出的异常。添加onError处理。 at rx.internal.schedulers.ScheduledAction.run（ScheduledAction.java:60） at android.os.Handler.handleCallback（Handler.java:733） at android.os.Handler.dispatchMessage（Handler.java:95） at android.os.Looper.loop（Looper.java:136） at android.app.ActivityThread.main（ActivityThread.java:5017） at java.lang.reflect.Method。invokeNative（Native Method） at java.lang.reflect.Method.invoke（Method.java:515） at com.android.internal.os.ZygoteInit $ MethodAndArgsCaller.run（ZygoteInit.java:779） at com.android .internal.os.ZygoteInit.main（ZygoteInit.java:595） at dalvik.system.NativeStart.main（Native Method）原因：rx.exceptions.OnErrorNotImplementedException：无法为方法创建rx.Observable 的调用适配器ApiInterface.postImage at rx.Observable $ 26.onError（Observable.java:8524） at rx.observers.SafeSubscriber._onError（SafeSubscriber.java:157） at rx.observ ers.SafeSubscriber.onError（SafeSubscriber.java:120） at rx.internal.operators.OperatorDoOnEach $ 1.onError（OperatorDoOnEach.java:71） at rx.exceptions.Exceptions.throwOrReport（Exceptions.java:189） at rx .internal.operators.OperatorDoOnEach $ 1.onNext（OperatorDoOnEach.java:82）在rx.internal.operators.OperatorObserveOn $ ObserveOnSubscriber.call（OperatorObserveOn.java:215）在rx.internal.schedulers.ScheduledAction.run（ScheduledAction。 java：55） ... 9更多导致：java.lang.IllegalArgumentException：无法为方法ApiInterface.postImage为rx.Observable 创建调用适配器在retrofit2.ServiceMethod $ Builder.methodError（ServiceMethod.java:695）在retrofit2.ServiceMethod $ Builder.createCallAdapter（ServiceMethod.java:233）在retrofit2.ServiceMethod $ Builder.build（ServiceMethod.java:159）在retrofit2.Retrofit.loadServiceMethod（Retrofit.java:166） at retrofit2.Refofit $ 1.invoke（Retrofit.java:145） at $ Proxy0.postImage（Native Method） at info.masterskaya.om.near.mvp.model （ModelImpl.java:53） at info.masterskaya.om.near.mvp.presenter.PresenterImpl $ 1.call（PresenterImpl.java:133） at info.masterskaya.om.near.mvp.pr esenter.PresenterImpl $ 1.call（PresenterImpl.java:119） at rx.Observable $ 11.onNext（Observable.java:4820） at rx.internal.operators.OperatorDoOnEach $ 1.onNext（OperatorDoOnEach.java:80） .. 11更引起：java.lang.IllegalStateException：响应必须被参数化为在retrofit2.adapter.rxjava.RxJavaCallAdapterFactory.getCallAdapter（RxJavaCallAdapterFactory.java:119）响应或响应在retrofit2.adapter.rxjava.RxJavaCallAdapterFactory.get （RxJavaCallAdapterFactory.java:105） at retrofit2.Retrofit.nextCallAdapter（Retrofit.java:217） at retrofit2.Retrofit.callAdapter（Retrofit.java:20 1） at retrofit2.ServiceMethod $ Builder.createCallAdapter（ServiceMethod.java:231） ... 20个以上由rx.exceptions.OnErrorThrowable引起$ OnNextValue：发出onNext值时的OnError：android.net.Uri $ HierarchicalUri。类 at rx.exceptions.Exceptions.throwOrReport（Exceptions.java:189） at rx.internal.operators.OperatorDoOnEach $ 1.onNext（OperatorDoOnEach.java:82） ...11多

如果我改变我的接口：

@Multipart 
    @POST("/upload/index.php") 
    Observable<String> postImage(@Part MultipartBody.Part image, @Part("name") RequestBody name);

我有这样的痕迹：

* E/AndroidRuntime：致命异常：主要过程：info.masterskaya.om.near， PID：8618 java.lang.IllegalStateException：在Scheduler.Worker线程上抛出的异常。添加onError处理。 at rx.internal.schedulers.ScheduledAction.run（ScheduledAction.java:60） at android.os.Handler.handleCallback（Handler.java:733） at android.os.Handler.dispatchMessage（Handler.java:95） at android.os.Looper.loop（Looper.java:136） at android.app.ActivityThread.main（ActivityThread.java:5017） at java.lang.reflect.Method.invokeNative（Native Method） at java .lang.reflect.Method.invoke（Method.java:515） at com.android.internal.os.ZygoteInit $ MethodAndArgsCaller.run（ZygoteInit.java:779） at com.android.internal.os.ZygoteInit.main （ZygoteInit.java:595） at dalvik.system.NativeStart.main（Native Method）由rx.exceptions.OnErrorNotImplementedException引起：/ document/image：34：打开失败：ENOENT（无此类文件或目录） at rx.Observable $ 26.onError（ Observable.java:8524）在rx.observers.SafeSubscriber._onError（SafeSubscriber.java:157）在rx.observers.SafeSubscriber.onError（SafeSubscriber.java:120）在rx.internal.operators.OperatorObserveOn $ ObserveOnSubscriber。 checkTerminated（OperatorObserveOn.java:264） at rx.internal.operators.OperatorObserveOn $ ObserveOnSubscriber.call（OperatorObserveOn.java:207） at rx.internal.schedulers.ScheduledAct ion.run（ScheduledAction.java:55） at android.os.Handler.handleCallback（Handler.java:733） at android.os.Handler.dispatchMessage（Handler.java:95） at android.os.Looper。在java.lang.reflect.Method.invoke处使用循环（Looper.java:136）（Method.java:515） at com.android.internal.os.ZygoteInit $ MethodAndArgsCaller.run（ZygoteInit.java:779） at com.android.internal.os.ZygoteInit.main（ZygoteInit.java:595）在dalvik.system.Native Start.main（本地方法）引起：java.io.FileNotFoundException：/ document/image：34：打开失败：ENOENT（没有这样的文件或目录） at libcore.io.IoBridge.open（IoBridge.java:409 ）在java.io.FileInputStream中。（FileInputStream.java:78）在okio.Okio.source（Okio.java:163）在okhttp3.RequestBody $ 3.writeTo（RequestBody.java:117）在okhttp3.MultipartBody .writeOrCountBytes（MultipartBody.java:171） at okhttp3.MultipartBody.writeTo（MultipartBody.java:113） at okhttp3.logging.HttpLoggingInterceptor.intercept（HttpLoggingInterceptor.java:186） at ok http3.RealCall $ ApplicationInterceptorChain.proceed（RealCall.java:187） at okhttp3.RealCall。getResponseWithInterceptorChain（RealCall.java:160）在okhttp3.RealCall.execute（RealCall.java:57）在retrofit2.OkHttpCall.execute（OkHttpCall.java:174）在retrofit2.adapter.rxjava.RxJavaCallAdapterFactory $ RequestArbiter.request（ RxJavaCallAdapterFactory.java:171）在rx.internal.operators.OperatorSubscribeOn $ 1 $ 1 $ 1.request（OperatorSubscribeOn.java:80）在rx.Subscriber.setProducer（Subscriber.java:211）在rx.internal.operators.OperatorSubscribeOn $ 1 $ 1.setProducer（OperatorSubscribeOn.java:76） at rx.Subscriber.setProducer（Subscriber.java:205） at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory $ CallOnSubscribe.call（RxJavaCallAdapterFactory.java:152）在retrofit2.adapter.rxjava.RxJavaCallAdapterFactory $ CallOnSubscribe.call（RxJavaCallAdapterFactory.java:138）在rx.Observable $ 2.call（Observable.java:233）在rx.Observable $ 2.call（Observable.java:225） at rx.Observable.unsafeSubscribe（Observable.java:8741） at rx.internal.operators.OperatorSubscribeOn $ 1.call（OperatorSubscribeOn.java:94） at rx.internal.schedulers .ScheduledAction.run（ScheduledAction.java:55） at java.util.concurrent.Executors $ RunnableAdapter.call（Executors.java:422） at java.util.concurrent.FutureTask.run（FutureTask.java： 237）处的java.util.concurrent java.util.concurrent.ScheduledThreadPoolExecutor中$ $ ScheduledFutureTask.access 201（ScheduledThreadPoolExecutor.java:152）在java.util.concurrent.ScheduledThreadPoolExecutor中$ ScheduledFutureTask.run（ScheduledThreadPoolExecutor.java:265） .ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java:1112） at java.util.concurrent.ThreadPoolExecutor $ Worker.run（ThreadPoolExecutor.java:587） at java.lang.Thread.run（Thread.java:841）由：libcore.io.ErrnoException：打开失败：ENOENT（无此文件或目录）

                 at libcore.io.BlockGuardOs.open(BlockGuardOs.java:110) 
                     at libcore.io.IoBridge.open(IoBridge.java:393) 
                     at java.io.FileInputStream.<init>(FileInputStream.java:78)  
                     at okio.Okio.source(Okio.java:163)  
                     at okhttp3.RequestBody$3.writeTo(RequestBody.java:117)  
                     at okhttp3.MultipartBody.writeOrCountBytes(MultipartBody.java:171)  
                     at okhttp3.MultipartBody.writeTo(MultipartBody.java:113)  
                     at okhttp3.logging.HttpLoggingInterceptor.intercept(HttpLoggingInterceptor.java:186)  
                     at okhttp3.RealCall$ApplicationInterceptorChain.proceed(RealCall.java:187)  
                     at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:160)  
                     at okhttp3.RealCall.execute(RealCall.java:57)  
                     at retrofit2.OkHttpCall.execute(OkHttpCall.java:174)  
                     at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:171)  
                     at rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)  
                     at rx.Subscriber.setProducer(Subscriber.java:211)  
                     at rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)  
                     at rx.Subscriber.setProducer(Subscriber.java:205)  
                     at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152)  
                     at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138)  
                     at rx.Observable$2.call(Observable.java:233)  
                     at rx.Observable$2.call(Observable.java:225)  
                     at rx.Observable.unsafeSubscribe(Observable.java:8741)  
                     at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)  
                     at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)  
                     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:422)  
                     at java.util.concurrent.FutureTask.run(FutureTask.java:237)  
                     at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:152)  
                     at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:265)  
                     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1112)  
                     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:587)  
                     at java.lang.Thread.run(Thread.java:841)*

UPD4：

我有一些结果。

接口：

@Multipart 
@POST("/upload/index.php") 
Observable<Void> postImage(@Part MultipartBody.Part image, @Part("name") RequestBody name);

主要功能：

RxPhoto.requestUri(context,TypeRequest.GALLERY) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .doOnNext(new Action1<Uri>(){ 

        @Override 
        public void call(Uri uri) { 

         Log.d(tag, "up => " + uri); 
         Log.d(tag, "getPath => " + getPath(context,uri)); 

         String URL = getPath(context,uri); 

         File file = new File(URL+""); 

         RequestBody reqFile = RequestBody.create(MediaType.parse("image/*"), file); 
         MultipartBody.Part body = MultipartBody.Part.createFormData("upload", file.getName(), reqFile); 
         RequestBody name = RequestBody.create(MediaType.parse("text/plain"), "upload_test"); 

         GetDataSubscription = model.postImage(body,name) 
           .subscribeOn(Schedulers.io()) 
           .observeOn(AndroidSchedulers.mainThread()) 
           .subscribe(); 

        } 

       }) 
       .subscribe();

/~~~~~~~/

getPath(context,uri)

我发现HERE

现在我有服务器错误：

12-09 05:37:55.760 10230-10372/* D/OkHttp: --857d62de-296c-4d23-8683-92b3b340a658 12-09 05:37:55.760 10230-10372/ D/OkHttp: Content-Disposition: form-data; name="upload"; filename="IMG_20161206_092257.jpg" 12-09 05:37:55.760 10230-10372/ D/OkHttp: Content-Type: multipart/form-data 12-09 05:37:55.760 10230-10372/* D/OkHttp: Content-Length: 26188

...

12-09 05:37:55.770 10230-10372/* D/OkHttp: --857d62de-296c-4d23-8683-92b3b340a658 12-09 05:37:55.770 10230-10372/ D/OkHttp: Content-Disposition: form-data; name="name" 12-09 05:37:55.770 10230-10372/ D/OkHttp: Content-Transfer-Encoding: binary 12-09 05:37:55.770 10230-10372/ D/OkHttp: Content-Type: multipart/form-data; charset=utf-8 12-09 05:37:55.770 10230-10372/ D/OkHttp: Content-Length: 11 12-09 05:37:55.770 10230-10372/ D/OkHttp: upload_test 12-09 05:37:55.770 10230-10372/ D/OkHttp: --857d62de-296c-4d23-8683-92b3b340a658-- 12-09 05:37:55.770 10230-10372/ D/OkHttp: --> END POST (26620-byte body) 12-09 05:37:55.800 10230-10334/ D/GoogleCertificatesImpl: Fetched 363 Google certificates 12-09 05:37:56.340 10230-10230/ I/Choreographer: Skipped 42 frames! The application may be doing too much work on its main thread. 12-09 05:37:56.390 10230-10372/ D/OkHttp: <-- 200 OK http://www ./upload/index.php (604ms) 12-09 05:37:56.390 10230-10372/ D/OkHttp: Date: Fri, 09 Dec 2016 10:37:56 GMT 12-09 05:37:56.390 10230-10372/ D/OkHttp: Server: Apache 12-09 05:37:56.390 10230-10372/ D/OkHttp: Vary: Accept-Encoding 12-09 05:37:56.390 10230-10372/ D/OkHttp: Content-Type: text/html; charset=UTF-8 12-09 05:37:56.390 10230-10372/ D/OkHttp: X-Cache: MISS from t7..ru 12-09 05:37:56.390 10230-10372/ D/OkHttp: X-Cache-Lookup: MISS from t7..ru:6666 12-09 05:37:56.390 10230-10372/ D/OkHttp: Connection: keep-alive 12-09 05:37:56.390 10230-10372/ D/OkHttp: OkHttp-Sent-Millis: 1481279876016 12-09 05:37:56.390 10230-10372/ D/OkHttp: OkHttp-Received-Millis: 1481279876396 12-09 05:37:56.390 10230-10372/* D/OkHttp: {"result": "fail"} 12-09 05:37:56.390 10230-10372/*** D/OkHttp: <-- END HTTP (18-byte body)

服务器：

<?php 

    $file_path = "up/"; 

    $file_path = $file_path . basename($_FILES['uploaded_file']['name']); 
    if(move_uploaded_file($_FILES['uploaded_file']['tmp_name'], $file_path)){ 
     echo '{"result": "success"}'; 
    } else{ 
     echo '{"result": "fail"}'; 
    } 
?>

UPD5：

我做到了这一点他妈的上传！

PHP测试代码：

<?php 

    error_reporting(E_ALL); 
    ini_set('display_errors', 1); 

    define('ROOT_DIR', dirname(__FILE__)); 

    $file_path = ROOT_DIR . ""; 

    $file_path = $file_path . basename($_FILES['upload']['name']); 
    if(move_uploaded_file($_FILES['upload']['tmp_name'], $file_path)){ 
     echo '{"result": "success"}'; 
    } else{ 
     echo '{"result": "fail"}'; 
    } 
?>

所有我遇到的问题是对设备正确URI。尝试API 16,19和24全部成功

来源

2016-12-05 Oleg Miroshin

你解决了这个错误的响应？ –

感谢您对我的问题的支持和兴趣，我曾经调试过 StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder（）。permitAll（）。build（）; StrictMode.setThreadPolicy（policy）; –

那一个不好的选项，你可以使用调度程序的NetworkOnMainThreadException –

包含呼叫适配器工厂，如果您忘记了它。

RxJava2：compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'

RxJava：compile 'com.squareup.retrofit:adapter-rxjava:2.0.0-beta2'

编辑：

好，是因为你需要转换multipart，不text，这样的变化将出现在这里：

RequestBody name = RequestBody.create(MediaType.parse("multipart/form-data"), "upload_test");

mediatype也应该是山姆e

RequestBody reqFile = RequestBody.create(MediaType.parse("multipart/form-data"), file);`

欲了解更多信息，请看看here。

来源

2016-12-05 08:50:32

不，同样的错误:( –

在这个错误我想是因为你已经添加了两行相同的库。我认为你的问题是这样的 –

请阅读我的更新 –

如果name参数只是字符串，我认为API应该这样调用：

public interface ApiInterface { 
    @Multipart 
     @POST("/android/upload/index.php") 
     Observable<Response> postImage(@Part MultipartBody.Part image, @Part("name") String name); 
}

来源

2016-12-05 09:15:19

请阅读我的更新 –

的问题是在以下部分：

Observable<Response>

响应总是需要指定体型。它看起来像你的回应没有一个身体，所以你应该与此替换它：

Observable<Result<Void>>

...，并要求使用result.response()

来源

2017-06-15 09:32:34

RxJava：无法为rx.Observable错误创建呼叫转接

回答

相关问题