blocks|key|4450461|text|我建议使用可重用的Transformer和onErrorResumeNext运算符来封装您的逻辑。它看起来像这样：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4450462|<T>+Observable.Transformer<T,+T>+parseHttpErrors()+{
++++return+new+Observable.Transformer<T,+T>()+{
++++++++@Override
++++++++public+Observable<T>+call(Observable<T>+observable)+{
++++++++++++return+observable.onErrorResumeNext(new+Func1<Throwable,+Observable<?+extends+T>>()+{
++++++++++++++++@Override
++++++++++++++++public+Observable<?+extends+T>+call(Throwable+throwable)+{
++++++++++++++++++++if+(throwable+instanceof+HttpException)+{
++++++++++++++++++++++++HttpErrorPojo+errorPojo+=+//+deserialize+throwable.response().errorBody();

++++++++++++++++++++++++//+Here+you+have+two+options,+one+is+report+this+pojo+back+as+error+(onError()+will+be+called),
++++++++++++++++++++++++return+Observable.error(errorPojo);+//+in+this+case+HttpErrorPojo+would+need+to+inherit+from+Throwable

++++++++++++++++++++++++//+or+report+this+pojo+back+as+part+of+onNext()
++++++++++++++++++++++++return+Observable.just(errorPojo);+//in+this+case+HttpErrorPojo+would+need+to+inherit+from+<T>
++++++++++++++++++++}
++++++++++++++++++++//+if+not+the+kind+we're+interested+in,+then+just+report+the+same+error+to+onError()
++++++++++++++++++++return+Observable.error(throwable);
++++++++++++++++}
++++++++++++});
++++++++}
++++};
}|code-block|syntax|javascript|4450463|注意代码中的注释，因为您必须决定是报告解析后的响应onError()还是onNext()。|4450464|然后，您可以在API调用中的任何位置使用此转换器，如下所示：|4450465|mConnect.login(id,+password)
++++++++.compose(this.<Token>parseHttpErrors())+//+<--+HERE
++++++++.subscribe(new+Subscriber<Token>()+{
++++++++++++@Override
++++++++++++public+void+onCompleted()+{
++++++++++++++++Log.d(TAG,+"onCompleted()");
++++++++++++}

++++++++++++@Override
++++++++++++public+void+onError(Throwable+e)+{
++++++++++++++++Log.e(TAG,+"onError():+"+%2B+e);
++++++++++++++++if+(e+instanceof+HttpErrorPojo)+{
++++++++++++++++++//+this+will+be+called+if+errorPojo+was+reported+via+Observable.error()
++++++++++++++++}
++++++++++++}

++++++++++++@Override
++++++++++++public+void+onNext(Token+token)+{
++++++++++++++++Log.d(TAG,+"onNext():+"+%2B+token);
++++++++++++++++if+(token+instanceof+HttpErrorPojo)+{
++++++++++++++++++//+this+will+be+called+if+errorPojo+was+reported+via+Observable.just()
++++++++++++++++}
++++++++++++}
++++++++});|4450466|entityMap|0|LINK|mutability|MUTABLE|url|http://reactivex.io/RxJava/javadoc/rx/Observable.Transformer.html|1|https://github.com/ReactiveX/RxJava/wiki/Error-Handling-Operators^0|9|B|0|L|H|1|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|Y|8|@]|9|@$A|Z|B|10|1|11]|$A|12|B|13|1|14]]|C|$]]|$1|D|3|E|5|F|7|15|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|16|8|@]|9|@]|C|$]]|$1|K|3|L|5|6|7|17|8|@]|9|@]|C|$]]|$1|M|3|N|5|F|7|18|8|@]|9|@]|C|$G|H]]|$1|O|3|-4|5|6|7|19|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]|W|$5|R|S|T|C|$U|X]]]]

I would suggest the use of a reusable <a href="http://reactivex.io/RxJava/javadoc/rx/Observable.Transformer.html" rel="noreferrer">Transformer</a> along with the <a href="https://github.com/ReactiveX/RxJava/wiki/Error-Handling-Operators" rel="noreferrer">onErrorResumeNext</a> operator to encapsulate your logic. It'd look something like this:

<pre><code>&lt;T&gt; Observable.Transformer&lt;T, T&gt; parseHttpErrors() {
 return new Observable.Transformer&lt;T, T&gt;() {
 @Override
 public Observable&lt;T&gt; call(Observable&lt;T&gt; observable) {
 return observable.onErrorResumeNext(new Func1&lt;Throwable, Observable&lt;? extends T&gt;&gt;() {
 @Override
 public Observable&lt;? extends T&gt; call(Throwable throwable) {
 if (throwable instanceof HttpException) {
 HttpErrorPojo errorPojo = // deserialize throwable.response().errorBody();

 // Here you have two options, one is report this pojo back as error (onError() will be called),
 return Observable.error(errorPojo); // in this case HttpErrorPojo would need to inherit from Throwable

 // or report this pojo back as part of onNext()
 return Observable.just(errorPojo); //in this case HttpErrorPojo would need to inherit from &lt;T&gt;
 }
 // if not the kind we're interested in, then just report the same error to onError()
 return Observable.error(throwable);
 }
 });
 }
 };
}
</code></pre>

Pay attention to the comments in the code, since you have to make the decision whether you want to report the parsed response onError() or onNext().

Then you can use this transformer anywhere in your API calls like this:

<pre><code>mConnect.login(id, password)
 .compose(this.&lt;Token&gt;parseHttpErrors()) // &lt;-- HERE
 .subscribe(new Subscriber&lt;Token&gt;() {
 @Override
 public void onCompleted() {
 Log.d(TAG, "onCompleted()");
 }

 @Override
 public void onError(Throwable e) {
 Log.e(TAG, "onError(): " + e);
 if (e instanceof HttpErrorPojo) {
 // this will be called if errorPojo was reported via Observable.error()
 }
 }

 @Override
 public void onNext(Token token) {
 Log.d(TAG, "onNext(): " + token);
 if (token instanceof HttpErrorPojo) {
 // this will be called if errorPojo was reported via Observable.just()
 }
 }
 });
</code></pre>

blocks|key|4450487|text|反序列化可能也是一个问题。您可以使用retrofit+converter+to+deserialize+it+(也可以自己动手)。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4450488|我的解决方案在murki的基础上增加了一点：|4450489|<T>+Observable.Transformer<T,+T>+parseHttpErrors()+{
++++++++return+new+Observable.Transformer<T,+T>()+{
++++++++++++@Override
++++++++++++public+Observable<T>+call(Observable<T>+observable)+{
++++++++++++++++return+observable.onErrorResumeNext(new+Func1<Throwable,+Observable<?+extends+T>>()+{
++++++++++++++++++++@Override
++++++++++++++++++++public+Observable<?+extends+T>+call(Throwable+throwable)+{
++++++++++++++++++++++++if+(+throwable+instanceof+HttpException+)+{
++++++++++++++++++++++++++++Retrofit+retrofit+=+new+Retrofit.Builder()
++++++++++++++++++++++++++++++++++++.baseUrl(SERVER_URL)+//+write+your+url+here
++++++++++++++++++++++++++++++++++++.addConverterFactory(GsonConverterFactory.create())
++++++++++++++++++++++++++++++++++++.build();
++++++++++++++++++++++++++++Converter<ResponseBody,+Error>+errorConverter+=
++++++++++++++++++++++++++++++++++++retrofit.responseBodyConverter(Error.class,+new+Annotation[0]);
++++++++++++++++++++++++++++//+Convert+the+error+body+into+our+Error+type.
++++++++++++++++++++++++++++try+{
++++++++++++++++++++++++++++++++Error+error+=+errorConverter.convert(((HttpException)+throwable).response().errorBody());
++++++++++++++++++++++++++++++++//+Here+you+have+two+options,+one+is+report+this+pojo+back+as+error+(onError()+will+be+called),
++++++++++++++++++++++++++++++++return+Observable.error(new+Throwable(error.getMessage()));
++++++++++++++++++++++++++++}
++++++++++++++++++++++++++++catch+(Exception+e2)+{
++++++++++++++++++++++++++++++++return+Observable.error(new+Throwable());
++++++++++++++++++++++++++++}

++++++++++++++++++++++++}
++++++++++++++++++++++++//+if+not+the+kind+we're+interested+in,+then+just+report+the+same+error+to+onError()
++++++++++++++++++++++++return+Observable.error(throwable);
++++++++++++++++++++}
++++++++++++++++});
++++++++++++}
++++++++};
++++}|code-block|syntax|javascript|4450490|然后在onError()中，|4450491|@Override
public+void+onError(Throwable+e)+{
++++progressBar.setVisibility(View.GONE);+//+optional+
++++if+(+!TextUtils.isEmpty(e.getMessage())+)+{
++++++++++++//+show+error+as+you+like+
++++++++++++return;
++++}
++++//+show+a+default+error+if+you+wish
}|4450492|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/square/retrofit/blob/master/samples/src/main/java/com/example/retrofit/DeserializeErrorBody.java^0|I|10|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|6|7|10|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|11|8|@]|9|@]|C|$I|J]]|$1|K|3|L|5|6|7|12|8|@]|9|@]|C|$]]|$1|M|3|N|5|H|7|13|8|@]|9|@]|C|$I|J]]|$1|O|3|-4|5|6|7|14|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]]]

Deserialize may be an issue too. You can use the <a href="https://github.com/square/retrofit/blob/master/samples/src/main/java/com/example/retrofit/DeserializeErrorBody.java" rel="nofollow">retrofit converter to deserialize it</a> (or do it yourself).

My solution adds a bit to the one from murki:

<pre><code>&lt;T&gt; Observable.Transformer&lt;T, T&gt; parseHttpErrors() {
 return new Observable.Transformer&lt;T, T&gt;() {
 @Override
 public Observable&lt;T&gt; call(Observable&lt;T&gt; observable) {
 return observable.onErrorResumeNext(new Func1&lt;Throwable, Observable&lt;? extends T&gt;&gt;() {
 @Override
 public Observable&lt;? extends T&gt; call(Throwable throwable) {
 if ( throwable instanceof HttpException ) {
 Retrofit retrofit = new Retrofit.Builder()
 .baseUrl(SERVER_URL) // write your url here
 .addConverterFactory(GsonConverterFactory.create())
 .build();
 Converter&lt;ResponseBody, Error&gt; errorConverter =
 retrofit.responseBodyConverter(Error.class, new Annotation[0]);
 // Convert the error body into our Error type.
 try {
 Error error = errorConverter.convert(((HttpException) throwable).response().errorBody());
 // Here you have two options, one is report this pojo back as error (onError() will be called),
 return Observable.error(new Throwable(error.getMessage()));
 }
 catch (Exception e2) {
 return Observable.error(new Throwable());
 }

 }
 // if not the kind we're interested in, then just report the same error to onError()
 return Observable.error(throwable);
 }
 });
 }
 };
 }
</code></pre>

and then at the onError(),

<pre><code>@Override
public void onError(Throwable e) {
 progressBar.setVisibility(View.GONE); // optional 
 if ( !TextUtils.isEmpty(e.getMessage()) ) {
 // show error as you like 
 return;
 }
 // show a default error if you wish
}
</code></pre>

I'm pretty new to RxJava and Retrofit and am trying to write my API calls with it. All the API calls return a JSON body on error which is in the general format as,

<pre><code>{"errors":[{"code":100, "message":"Login/Password not valid", "arguments":null}]}
</code></pre>

Currently my code for the login API call (others are also similar) is,

<pre><code>mConnect.login(id, password)
 .subscribe(new Subscriber&lt;Token&gt;() {
 @Override
 public void onCompleted() {
 Log.d(TAG, "onCompleted()");
 }

 @Override
 public void onError(Throwable e) {
 Log.e(TAG, "onError(): " + e);
 if (e instanceof HttpException) {
 // dump e.response().errorBody()
 }
 }

 @Override
 public void onNext(Token token) {
 Log.d(TAG, "onNext(): " + token);
 }
 });
</code></pre>

When I get an error at the onError(), I would like to automatically decode the JSON in the error body to a POJO instead and use that. Is there a way to do this preferably in one place for all other API calls. Any help is appreciated.

Retrofit 2.0 + RxJava + Error JSON body

JSON

我对RxJava和Retrofit非常陌生，正在尝试用它来编写我的应用程序接口调用。所有API调用在出错时都返回JSON主体，其一般格式为，{"errors":[{"code":100, "message":"Login/Password not valid", "arguments":null}]}目前我的登录API...

问改进2.0 + RxJava + Error JSON body
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问改进2.0 + RxJava + Error JSON bodyEN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问改进2.0 + RxJava + Error JSON body
EN