io.reactivex.Observable.singleOrError()方法的使用及代码示例

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

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

Observable.singleOrError介绍

[英]Returns a Single that emits the single item emitted by this Observable if this Observable emits only a single item, otherwise if this Observable completes without emitting any items or emits more than one item a NoSuchElementException or IllegalArgumentException will be signalled respectively.

Scheduler: singleOrError does not operate by default on a particular Scheduler.
[中]如果此可观测对象仅发射单个项,则返回发射此可观测对象发射的单个项的单个项;否则,如果此可观测对象在未发射任何项的情况下完成,或发射多个项,则将分别发出NosTouchElementException或IllegalArgumentException信号。
调度程序:默认情况下,singleOrError不会在特定调度程序上运行。

代码示例

代码示例来源:origin: lettuce-io/lettuce-core

  1. @Override
  2. public io.reactivex.Single<?> apply(io.reactivex.Observable<?> source) {
  3. return source.singleOrError();
  4. }
  5. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Override
  2. public SingleSource<Object> apply(Observable<Object> o) throws Exception {
  3. return o.singleOrError();
  4. }
  5. });

代码示例来源:origin: ReactiveX/RxJava

  1. @Override
  2. public Object apply(Observable<Object> o) throws Exception {
  3. return o.singleOrError();
  4. }
  5. }, false, 1, 1, 1);

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public <T> Single<T> getObjectSingle(Class<T> objectClass) {
  2. return getObjectObservable(objectClass).singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public Single<String> getStringSingle() {
  2. return getStringObservable().singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public Single<JSONArray> getJSONArraySingle() {
  2. return getJSONArrayObservable().singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public Single<Bitmap> getBitmapSingle() {
  2. return getBitmapObservable().singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public Single<String> getDownloadSingle() {
  2. return getDownloadObservable().singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public <T> Single<T> getParseSingle(TypeToken<T> typeToken) {
  2. return getParseObservable(typeToken).singleOrError();
  3. }

代码示例来源:origin: amitshekhariitbhu/Fast-Android-Networking

  1. public <T> Single<List<T>> getObjectListSingle(Class<T> objectClass) {
  2. return getObjectListObservable(objectClass).singleOrError();
  3. }

代码示例来源:origin: jeasonlzy/okhttp-OkGo

  1. @Override
  2. public Single<Response<T>> adapt(Call<T> call, AdapterParam param) {
  3. ObservableResponse<T> observable = new ObservableResponse<>();
  4. return observable.adapt(call, param).singleOrError();
  5. }
  6. }

代码示例来源:origin: jeasonlzy/okhttp-OkGo

  1. @Override
  2. public Single<Result<T>> adapt(Call<T> call, AdapterParam param) {
  3. ObservableResult<T> observable = new ObservableResult<>();
  4. return observable.adapt(call, param).singleOrError();
  5. }
  6. }

代码示例来源:origin: jeasonlzy/okhttp-OkGo

  1. @Override
  2. public Single<T> adapt(Call<T> call, AdapterParam param) {
  3. ObservableBody<T> observable = new ObservableBody<>();
  4. return observable.adapt(call, param).singleOrError();
  5. }
  6. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void singleOrErrorOneElement() {
  3. Observable.just(1)
  4. .singleOrError()
  5. .test()
  6. .assertNoErrors()
  7. .assertValue(1);
  8. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void singleOrErrorMultipleElements() {
  3. Observable.just(1, 2, 3)
  4. .singleOrError()
  5. .test()
  6. .assertNoValues()
  7. .assertError(IllegalArgumentException.class);
  8. }

代码示例来源:origin: square/retrofit

  1. return observable.singleOrError();

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void singleOrErrorError() {
  3. Observable.error(new RuntimeException("error"))
  4. .singleOrError()
  5. .test()
  6. .assertNoValues()
  7. .assertErrorMessage("error")
  8. .assertError(RuntimeException.class);
  9. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void singleOrErrorNoElement() {
  3. Observable.empty()
  4. .singleOrError()
  5. .test()
  6. .assertNoValues()
  7. .assertError(NoSuchElementException.class);
  8. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void singleOrError() {
  3. Observable.empty()
  4. .singleOrError()
  5. .toObservable()
  6. .test()
  7. .assertFailure(NoSuchElementException.class);
  8. }
  9. }

代码示例来源:origin: ReactiveX/RxJava

  1. @Test
  2. public void toObservableAndBack() {
  3. Single.fromCallable(new Callable<Integer>() {
  4. @Override
  5. public Integer call() throws Exception {
  6. return 1;
  7. }
  8. })
  9. .toObservable()
  10. .singleOrError()
  11. .test()
  12. .assertResult(1);
  13. }
  14. }

相关文章

Observable类方法