io.reactivex.SingleObserver源码实例Demo-ICode联盟

类io.reactivex.SingleObserver源码实例Demo

下面列出了怎么用io.reactivex.SingleObserver的API类实例代码及写法，或者点击链接到github查看源代码。

源代码1 项目： 1Rramp-Android 文件： LeaderboardBar.java

/**
 * fetch leaderboard
 */
private void loadLeaders() {
  RetrofitServiceGenerator.getService().getLeaderboardList()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeWith(new SingleObserver<LeaderboardModel>() {
      @Override
      public void onSubscribe(Disposable d) {
        compositeDisposable.add(d);
      }

      @Override
      public void onSuccess(LeaderboardModel leaderboardModel) {
        handleLeaderBoardList(leaderboardModel);
      }

      @Override
      public void onError(Throwable e) {
      }
    });
}

源代码2 项目： JReadHub 文件： SearchPresenter.java

@Override
public void addHistory(SearchHistoryBean newDataBean) {
    mDataManager.getSingleHistory(newDataBean.getKeyWord())
            .compose(RxSchedulers.singleIo2Main())
            .subscribe(new SingleObserver<SearchHistoryBean>() {
                @Override
                public void onSubscribe(Disposable d) {
                    addSubscribe(d);
                }

                @Override
                public void onSuccess(SearchHistoryBean oldDataBean) {
                    oldDataBean.setTime(newDataBean.getTime());
                    updateHistory(oldDataBean);
                }

                @Override
                public void onError(Throwable e) {
                    if (e instanceof EmptyResultSetException) {
                        mDataManager.insert(newDataBean);
                    }
                }
            });
}

源代码3 项目： RxAndroid-Sample 文件： ExampleUnitTest.java

@Test
public void testContainsObservable() {

    Observable.just(1, 2, 3, 4, 5, 6)
            .contains(10)
            .subscribe(new SingleObserver<Boolean>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onSuccess(Boolean aBoolean) {
                    System.out.println("Does list contain value 10: " + aBoolean);
                }

                @Override
                public void onError(Throwable e) {

                }
            });
}

源代码4 项目： RxAndroid-Sample 文件： ExampleUnitTest.java

@Test
public void testCountObservable() {

    Observable.just(1, 2, 3, 4, 5)
            .count()
            .subscribe(new SingleObserver<Long>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onSuccess(Long aLong) {
                    System.out.println("Count: " + aLong);
                }

                @Override
                public void onError(Throwable e) {

                }
            });
}

源代码5 项目： reactive-grpc 文件： SubscribeOnlyOnceSingleOperator.java

@Override
public SingleObserver<? super T> apply(final SingleObserver<? super T> observer) {
    return new SingleObserver<T>() {
        @Override
        public void onSubscribe(Disposable d) {
            if (subscribedOnce.getAndSet(true)) {
                throw new NullPointerException("You cannot directly subscribe to a gRPC service multiple times " +
                        "concurrently. Use Flowable.share() instead.");
            } else {
                observer.onSubscribe(d);
            }
        }

        @Override
        public void onSuccess(T t) {
            observer.onSuccess(t);
        }

        @Override
        public void onError(Throwable e) {
            observer.onError(e);
        }
    };
}

源代码6 项目： reactive-grpc 文件： SubscribeOnlyOnceTest.java

@Test
public void subscribeOnlyOnceSingleOperatorErrorsWhenMultipleSubscribe() {
    SubscribeOnlyOnceSingleOperator<Object> op = new SubscribeOnlyOnceSingleOperator<Object>();
    SingleObserver<Object> innerSub = mock(SingleObserver.class);
    final Disposable disposable = mock(Disposable.class);

    final SingleObserver<Object> outerSub = op.apply(innerSub);

    outerSub.onSubscribe(disposable);
    assertThatThrownBy(new ThrowableAssert.ThrowingCallable() {
        @Override
        public void call() {
            outerSub.onSubscribe(disposable);
        }
    })
            .isInstanceOf(NullPointerException.class)
            .hasMessageContaining("cannot directly subscribe to a gRPC service multiple times");

    verify(innerSub, times(1)).onSubscribe(disposable);
}

源代码7 项目： NovelReader 文件： BookDetailPresenter.java

private void refreshBook(){
    RemoteRepository
            .getInstance()
            .getBookDetail(bookId)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new SingleObserver<BookDetailBean>() {
                @Override
                public void onSubscribe(Disposable d) {
                    addDisposable(d);
                }

                @Override
                public void onSuccess(BookDetailBean value){
                    mView.finishRefresh(value);
                    mView.complete();
                }

                @Override
                public void onError(Throwable e) {
                    mView.showError();
                }
            });
}

源代码8 项目： Android-AudioRecorder-App 文件： PlayListPresenterImpl.java

@Override public void renameFile(int adapterPosition, String value) {
  rename(recordingItems.get(adapterPosition), adapterPosition, value).subscribe(
      new SingleObserver<Integer>() {
        @Override public void onSubscribe(Disposable d) {

        }

        @Override public void onSuccess(Integer position) {
          getAttachedView().notifyListItemChange(position);
        }

        @Override public void onError(Throwable e) {
          getAttachedView().showError(e.getMessage());
        }
      });
}

源代码9 项目： J2ME-Loader 文件： MicroActivity.java

@SuppressLint("CheckResult")
private void takeScreenshot() {
	microLoader.takeScreenshot((Canvas) current)
			.subscribeOn(Schedulers.computation())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(new SingleObserver<String>() {
				@Override
				public void onSubscribe(Disposable d) {
				}

				@Override
				public void onSuccess(String s) {
					Toast.makeText(MicroActivity.this, getString(R.string.screenshot_saved)
							+ " " + s, Toast.LENGTH_LONG).show();
				}

				@Override
				public void onError(Throwable e) {
					e.printStackTrace();
					Toast.makeText(MicroActivity.this, R.string.error, Toast.LENGTH_SHORT).show();
				}
			});
}

源代码10 项目： rxjava2-jdbc 文件： MemberSingle.java

@Override
protected void subscribeActual(SingleObserver<? super Member<T>> observer) {
    // the action of checking out a member from the pool is implemented as a
    // subscription to the singleton MemberSingle
    MemberSingleObserver<T> m = new MemberSingleObserver<T>(observer, this);
    observer.onSubscribe(m);
    if (pool.isClosed()) {
        observer.onError(new PoolClosedException());
        return;
    }
    add(m);
    if (m.isDisposed()) {
        remove(m);
    } else {
        // atomically change requested
        while (true) {
            Observers<T> a = observers.get();
            if (observers.compareAndSet(a, a.withRequested(a.requested + 1))) {
                break;
            }
        }
    }
    log.debug("subscribed");
    drain();
}

源代码11 项目： mimi-reader 文件： NavDrawerFragment.java

private void postUread(String boardName, long threadId, @NonNull UnreadCountUpdate callback) {
    HistoryTableConnection.fetchPost(boardName, threadId)
            .subscribeOn(Schedulers.computation())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new SingleObserver<History>() {
                @Override
                public void onSubscribe(Disposable d) {
                    // no op
                }

                @Override
                public void onSuccess(History history) {
                    callback.OnUnreadCountUpdate(history.unreadCount);
                }

                @Override
                public void onError(Throwable e) {
                    Log.e(LOG_TAG, "Error setting unread count badge", e);
                }
            });
}

源代码12 项目： AppOpsX 文件： PermPresenter.java

void autoDisable() {
  Helper.autoDisable(context, appInfo.packageName)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleObserver<SparseIntArray>() {

        @Override
        public void onSubscribe(Disposable d) {
        }

        @Override
        public void onSuccess(SparseIntArray value) {
          autoDisabled = true;
          load();
        }

        @Override
        public void onError(Throwable e) {
          autoDisabled = true;
          load();
        }
      });
}

源代码13 项目： AppOpsX 文件： PermPresenter.java

void reset(){
  Helper.resetMode(context, appInfo.packageName)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleObserver<OpsResult>(){

        @Override
        public void onSubscribe(@NonNull Disposable d) {

        }

        @Override
        public void onSuccess(@NonNull OpsResult opsResult) {
          load();
        }

        @Override
        public void onError(@NonNull Throwable e) {

        }
      });
}

源代码14 项目： AppOpsX 文件： AppPermissionActivity.java

private void loadAppinfo(String pkgName){
  Helper.getAppInfo(getApplicationContext(),pkgName)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleObserver<AppInfo>() {
        @Override
        public void onSubscribe(@NonNull Disposable d) {

        }

        @Override
        public void onSuccess(@NonNull AppInfo appInfo) {
          setTitle(appInfo.appName);
        }

        @Override
        public void onError(@NonNull Throwable e) {

        }
      });
}

源代码15 项目： AppOpsX 文件： MainActivity.java

private void loadUsers(){
  Helper.getUsers(getApplicationContext(),true).subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleObserver<List<UserInfo>>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onSuccess(List<UserInfo> userInfos) {

          Users.getInstance().updateUsers(userInfos);
          invalidateOptionsMenu();
        }

        @Override
        public void onError(Throwable e) {

        }
      });
}

源代码16 项目： AppOpsX 文件： SettingsActivity.java

private void closeServer() {
  Helper.closeBgServer(getActivity().getApplicationContext()).subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread()).subscribe(new SingleObserver<Boolean>() {
    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onSuccess(Boolean value) {
      Activity activity = getActivity();
      if (activity != null) {
        Toast.makeText(activity, R.string.bg_closed, Toast.LENGTH_SHORT).show();
      }
    }

    @Override
    public void onError(Throwable e) {

    }
  });
}

源代码17 项目： AppOpsX 文件： AppInstalledReceiver.java

private void showDlg(final Context context, String pkg) {
  Helper.getAppInfo(context, pkg)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleObserver<AppInfo>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onSuccess(AppInfo value) {
          Intent intent = new Intent(context, AlertInstalledPremActivity.class);
          intent.putExtra(AlertInstalledPremActivity.EXTRA_APP, value);
          intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
          intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
          context.startActivity(intent);
        }

        @Override
        public void onError(Throwable e) {

        }
      });
}

源代码18 项目： science-journal 文件： MaybeConsumers.java

/**
 * Performs the opposite translation from {@link
 * MaybeConsumers#fromSingleObserver(SingleObserver)}
 */
public static <T> SingleObserver<T> toSingleObserver(final MaybeConsumer<T> c) {
  return new SingleObserver<T>() {
    @Override
    public void onSubscribe(@NonNull Disposable d) {
      // do nothing
    }

    @Override
    public void onSuccess(@NonNull T t) {
      c.success(t);
    }

    @Override
    public void onError(@NonNull Throwable e) {
      c.fail(new RuntimeException(e));
    }
  };
}

源代码19 项目： Learning-Resources 文件： ObserverUtil.java

/**
 * @return SingleObserver with which observable will subscribe
 */
public static <T> SingleObserver<T> getSingleObserver(final CompositeDisposable compositeDisposable,
                                                      final WebserviceBuilder.ApiNames apiNames,
                                                      final SingleCallback tSingleCallback) {
    return new SingleObserver<T>() {

        @Override
        public void onSubscribe(Disposable d) {
            if (compositeDisposable != null) compositeDisposable.add(d);
        }

        @Override
        public void onSuccess(@NonNull T t) {
            if (tSingleCallback != null) tSingleCallback.onSingleSuccess(t, apiNames);
        }


        @Override
        public void onError(Throwable e) {
            if (tSingleCallback != null) tSingleCallback.onFailure(e, apiNames);
        }
    };
}

源代码20 项目： RxJava2-Android-Samples 文件： FlowableExampleActivity.java

private SingleObserver<Integer> getObserver() {

        return new SingleObserver<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, " onSubscribe : " + d.isDisposed());
            }

            @Override
            public void onSuccess(Integer value) {
                textView.append(" onSuccess : value : " + value);
                textView.append(AppConstant.LINE_SEPARATOR);
                Log.d(TAG, " onSuccess : value : " + value);
            }

            @Override
            public void onError(Throwable e) {
                textView.append(" onError : " + e.getMessage());
                textView.append(AppConstant.LINE_SEPARATOR);
                Log.d(TAG, " onError : " + e.getMessage());
            }
        };
    }

源代码21 项目： RxJava2-Android-Samples 文件： SingleObserverExampleActivity.java

private SingleObserver<String> getSingleObserver() {
    return new SingleObserver<String>() {
        @Override
        public void onSubscribe(Disposable d) {
            Log.d(TAG, " onSubscribe : " + d.isDisposed());
        }

        @Override
        public void onSuccess(String value) {
            textView.append(" onNext : value : " + value);
            textView.append(AppConstant.LINE_SEPARATOR);
            Log.d(TAG, " onNext value : " + value);
        }

        @Override
        public void onError(Throwable e) {
            textView.append(" onError : " + e.getMessage());
            textView.append(AppConstant.LINE_SEPARATOR);
            Log.d(TAG, " onError : " + e.getMessage());
        }
    };
}

源代码22 项目： RxJava2-Android-Samples 文件： LastOperatorExampleActivity.java

private SingleObserver<String> getObserver() {
    return new SingleObserver<String>() {

        @Override
        public void onSubscribe(Disposable d) {
            Log.d(TAG, " onSubscribe : " + d.isDisposed());
        }

        @Override
        public void onSuccess(String value) {
            textView.append(" onNext : value : " + value);
            textView.append(AppConstant.LINE_SEPARATOR);
            Log.d(TAG, " onNext value : " + value);
        }


        @Override
        public void onError(Throwable e) {
            textView.append(" onError : " + e.getMessage());
            textView.append(AppConstant.LINE_SEPARATOR);
            Log.d(TAG, " onError : " + e.getMessage());
        }
    };
}

源代码23 项目： vertx-jooq 文件： RXTestBase.java

protected <T> SingleObserver<T> countdownLatchHandler(final CountDownLatch latch){
    return new SingleObserver<T>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onSuccess(T t) {
            latch.countDown();
        }

        @Override
        public void onError(Throwable x) {
            x.printStackTrace();
            Assert.fail(x.getMessage());
            latch.countDown();
        }
    };
}

源代码24 项目： hex 文件： ArticleFragment.java

private void loadArticle() {
    SingleObserver observer = new SingleObserver<Story>() {
        @Override
        public void onSubscribe(Disposable d) {
        }

        @Override
        public void onSuccess(Story story) {
            mWebView.loadUrl(story.getUrl());
            hideArticleUnavailable();
        }

        @Override
        public void onError(Throwable e) {
            showArticleUnavailable();
            mSwipeRefreshLayout.setRefreshing(false);
        }
    };

    getStory().subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(observer);
}

源代码25 项目： hex 文件： StoryActivity.java

private void loadArticleTitle() {
    SingleObserver observer = new SingleObserver<Story>() {
        @Override
        public void onSubscribe(Disposable d) {
        }

        @Override
        public void onSuccess(Story story) {
            getSupportActionBar().setTitle(story.getTitle());
        }

        @Override
        public void onError(Throwable e) {
        }
    };

    mGetStory.subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(observer);
}

源代码26 项目： android-open-framework-analysis 文件： OperatorActivity.java

private void single() {
    Single.just(1).subscribe(new SingleObserver<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            Log.d(TAG, "onSubscribe: " + d.isDisposed());
        }

        @Override
        public void onSuccess(Integer integer) {
            Log.d(TAG, "onSuccess: " + integer);
        }

        @Override
        public void onError(Throwable e) {

        }
    });
}

源代码27 项目： future-converter 文件： RxJava2FutureUtils.java

@Override
protected void subscribeActual(SingleObserver<? super T> observer) {
    ValueSourceDisposable disposable = new ValueSourceDisposable();
    valueSource.addCallbacks(
        result -> {
            try {
                observer.onSuccess(result);
            } catch (Throwable e) {
                observer.onError(e);
            }
        },
        ex -> {
            if (!disposable.isDisposed()) {
                observer.onError(ex);
            }
        }
    );
    observer.onSubscribe(disposable);
}

源代码28 项目： vertx-rx 文件： SingleHelper.java

/**
 * Adapts an Vert.x {@code Handler<AsyncResult<T>>} to an RxJava2 {@link SingleObserver}.
 * <p>
 * The returned observer can be subscribed to an {@link Single#subscribe(SingleObserver)}.
 *
 * @param handler the handler to adapt
 * @return the observer
 */
public static <T> SingleObserver<T> toObserver(Handler<AsyncResult<T>> handler) {
  AtomicBoolean completed = new AtomicBoolean();
  return new SingleObserver<T>() {
    @Override
    public void onSubscribe(@NonNull Disposable d) {
    }
    @Override
    public void onSuccess(@NonNull T item) {
      if (completed.compareAndSet(false, true)) {
        handler.handle(Future.succeededFuture(item));
      }
    }
    @Override
    public void onError(Throwable error) {
      if (completed.compareAndSet(false, true)) {
        handler.handle(Future.failedFuture(error));
      }
    }
  };
}

源代码29 项目： rxjava-RxLife 文件： SingleLife.java

private void subscribeActual(SingleObserver<? super T> observer) {
    Single<T> upStream = this.upStream;
    if (onMain) {
        upStream = upStream.observeOn(AndroidSchedulers.mainThread());
    }
    upStream.onTerminateDetach().subscribe(new LifeSingleObserver<>(observer, scope));
}

源代码30 项目： 1Rramp-Android 文件： WinnerDeclarationActivity.java

private void registerPostPermlink() {
  SingleObserver<CompetitionCreateResponse> temp = RetrofitServiceGenerator.getService().registerCompetitionPermlink(
    mCompetitionId,
    REGISTER_PERMLINK_WINNER_DECLARE_TYPE,
    getFullpermlink())
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeWith(new SingleObserver<CompetitionCreateResponse>() {
      @Override
      public void onSubscribe(Disposable d) {

      }

      @Override
      public void onSuccess(CompetitionCreateResponse competitionCreateResponse) {
        showProgressDialog(false, "");
        HaprampPreferenceManager.getInstance().setLastPostCreatedAt(MomentsUtils.getCurrentTime());
        Toast.makeText(WinnerDeclarationActivity.this, "Winners blog posted!", Toast.LENGTH_LONG).show();
        finish();
      }

      @Override
      public void onError(Throwable e) {
        e.printStackTrace();
      }
    });
}

类所在包

io.reactivex

类方法

onError ( )

onSubscribe ( )

同包方法

io.reactivex.Observable

io.reactivex.schedulers.Schedulers

io.reactivex.disposables.Disposable

io.reactivex.android.schedulers.AndroidSchedulers

io.reactivex.Flowable

io.reactivex.functions.Consumer