rx.Observable.error()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(196)

本文整理了Java中rx.Observable.error()方法的一些代码示例，展示了Observable.error()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Observable.error()方法的具体详情如下：
包路径：rx.Observable
类名称：Observable
方法名：error

Observable.error介绍

[英]Returns an Observable that invokes an Observer's Observer#onError method when the Observer subscribes to it.

Scheduler: error does not operate by default on a particular Scheduler.
[中]返回一个Observable，当观察者订阅它时，它调用观察者的Observator#onError方法。
计划程序：默认情况下，错误不会在特定计划程序上运行。

代码示例

代码示例来源：origin: greenrobot/greenDAO

  1. @Override
  2.   public Observable<T> call() {
  3.     T result;
  4.     try {
  5.       result = callable.call();
  6.     } catch (Exception e) {
  7.       return Observable.error(e);
  8.     }
  9.     return Observable.just(result);
  10.   }
  11. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicySetDefinitionInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<PolicySetDefinitionInner>> result = listBuiltInDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<PolicySetDefinitionInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<ProviderInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<ProviderInner>> result = listNextDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<ProviderInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: PipelineAI/pipeline

  1. @Override
  2.   public Observable<R> call() {
  3.     try {
  4.       return Observable.just(getFallback());
  5.     } catch (Throwable ex) {
  6.       return Observable.error(ex);
  7.     }
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<TenantIdDescriptionInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl1<TenantIdDescriptionInner>> result = listNextDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<TenantIdDescriptionInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: hidroh/materialistic

  1. private Observable<Response> execute(Request request) {
  2.   return Observable.defer(() -> {
  3.     try {
  4.       return Observable.just(mCallFactory.newCall(request).execute());
  5.     } catch (IOException e) {
  6.       return Observable.error(e);
  7.     }
  8.   }).subscribeOn(mIoScheduler);
  9. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<FeatureResultInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<FeatureResultInner>> result = list1Delegate(response);
  5.       return Observable.just(new ServiceResponse<Page<FeatureResultInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: hidroh/materialistic

  1. @Override
  2. public void login(String username, String password, boolean createAccount, Callback callback) {
  3.   execute(postLogin(username, password, createAccount))
  4.       .flatMap(response -> {
  5.         if (response.code() == HttpURLConnection.HTTP_OK) {
  6.           return Observable.error(new UserServices.Exception(parseLoginError(response)));
  7.         }
  8.         return Observable.just(response.code() == HttpURLConnection.HTTP_MOVED_TEMP);
  9.       })
  10.       .observeOn(AndroidSchedulers.mainThread())
  11.       .subscribe(callback::onDone, callback::onError);
  12. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<TagDetailsInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<TagDetailsInner>> result = listNextDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<TagDetailsInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: PipelineAI/pipeline

  1. @Override
  2.   protected Observable<Boolean> resumeWithFallback() {
  3.     if (fallbackBehavior == FALLBACK_SUCCESS) {
  4.       return Observable.just(false);
  5.     } else if (fallbackBehavior == FALLBACK_FAILURE) {
  6.       RuntimeException ex = new RuntimeException("fallback failure");
  7.       if (asyncFallbackException) {
  8.         return Observable.error(ex);
  9.       } else {
  10.         throw ex;
  11.       }
  12.     } else { //FALLBACK_NOT_IMPLEMENTED
  13.       return super.resumeWithFallback();
  14.     }
  15.   }
  16. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<DeploymentOperationInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<DeploymentOperationInner>> result = listByResourceGroupDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<DeploymentOperationInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: hidroh/materialistic

  1. Observable.just(response) :
  2.     Observable.error(new IOException()))
  3. .flatMap(response -> {
  4.   try {
  5.     return Observable.just(new String[]{
  6.         response.header(HEADER_SET_COOKIE),
  7.         response.body().string()
  8.     });
  9.   } catch (IOException e) {
  10.     return Observable.error(e);
  11.   } finally {
  12.     response.close();
  13. })
  14. .flatMap(array -> !TextUtils.isEmpty(array[1]) ?
  15.     Observable.just(array) :
  16.     Observable.error(new IOException()))
  17. .flatMap(array -> execute(postSubmit(title, content, isUrl, array[0], array[1])))
  18. .flatMap(response -> response.code() == HttpURLConnection.HTTP_MOVED_TEMP ?
  19.     Observable.just(Uri.parse(response.header(HEADER_LOCATION))) :
  20.     Observable.error(new IOException()))
  21. .flatMap(uri -> TextUtils.equals(uri.getPath(), DEFAULT_SUBMIT_REDIRECT) ?
  22.     Observable.just(true) :
  23.     Observable.error(buildException(uri)))
  24. .observeOn(AndroidSchedulers.mainThread())
  25. .subscribe(callback::onDone, callback::onError);

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<DeploymentOperationInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<DeploymentOperationInner>> result = listByResourceGroupNextDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<DeploymentOperationInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Integer> construct() {
  3.   return Observable.just(1, 2, 3)
  4.       .concatWith(Observable.<Integer> error(new RuntimeException("forced error")))
  5.       .subscribeOn(Schedulers.computation());
  6. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<GenericResourceInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<GenericResourceInner>> result = listByResourceGroupNextDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<GenericResourceInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3.   return Observable.just(false, true, false)
  4.       .concatWith(Observable.<Boolean>error(new RuntimeException("forced error")))
  5.       .subscribeOn(Schedulers.computation());
  6. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyAssignmentInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl<PolicyAssignmentInner>> result = listByResourceGroupDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<PolicyAssignmentInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: PipelineAI/pipeline

  1. @HystrixCommand(
  2.     commandKey = COMMAND_KEY,
  3.     ignoreExceptions = {
  4.         BadRequestException.class,
  5.         NotFoundException.class
  6.     },
  7.     fallbackMethod = "fallback")
  8. public Observable<User> getUserById(String id) throws NotFoundException {
  9.   validate(id);
  10.   if (!USERS.containsKey(id)) {
  11.     return Observable.error(new NotFoundException("user with id: " + id + " not found"));
  12.   }
  13.   return Observable.just(USERS.get(id));
  14. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<SubscriptionInner>>> call(Response<ResponseBody> response) {
  3.     try {
  4.       ServiceResponse<PageImpl1<SubscriptionInner>> result = listDelegate(response);
  5.       return Observable.just(new ServiceResponse<Page<SubscriptionInner>>(result.body(), result.response()));
  6.     } catch (Throwable t) {
  7.       return Observable.error(t);
  8.     }
  9.   }
  10. });

代码示例来源：origin: hidroh/materialistic

  1. @Test
  2. public void testGetItemForceCacheUnsatisfiable() {
  3.   when(TestRestServiceFactory.hnRestService.cachedItemRx(eq("1")))
  4.       .thenReturn(Observable.error(new IOException()));
  5.   when(TestRestServiceFactory.hnRestService.itemRx(eq("1")))
  6.       .thenReturn(Observable.just(mock(HackerNewsItem.class)));
  7.   client.getItem("1", ItemManager.MODE_CACHE, itemListener);
  8.   verify(TestRestServiceFactory.hnRestService).cachedItemRx(eq("1"));
  9.   verify(TestRestServiceFactory.hnRestService).itemRx(eq("1"));
  10. }

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com