java类io.reactivex.SingleObserver的实例源码-面圈网

FlowableExampleActivity.java 文件源码项目：GitHub 阅读 28 收藏 0 点赞 0 评论 0

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());
            }
        };
    }

SingleObserverExampleActivity.java 文件源码项目：GitHub 阅读 30 收藏 0 点赞 0 评论 0

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());
        }
    };
}

LastOperatorExampleActivity.java 文件源码项目：GitHub 阅读 37 收藏 0 点赞 0 评论 0

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());
        }
    };
}

RxFacebookGraphRequestSingle.java 文件源码项目：RxFacebook 阅读 34 收藏 0 点赞 0 评论 0

@Override
protected void subscribeActual(@NonNull SingleObserver<? super GraphResponse> observer) {
    mObserver = observer;

    GraphRequest request = GraphRequest.newMeRequest(mAccessToken, new GraphRequest.GraphJSONObjectCallback() {
        @Override
        public void onCompleted(JSONObject object, GraphResponse response) {

            if (response.getError() == null) {
                mObserver.onSuccess(response);
            } else {
                mObserver.onError(response.getError().getException());
            }
        }
    });

    Bundle parameters = new Bundle();
    parameters.putString("fields", mFields);
    request.setParameters(parameters);
    request.executeAsync();
}

RxJava2FutureUtils.java 文件源码项目：reactive.loanbroker.system 阅读 27 收藏 0 点赞 0 评论 0

@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);
}

SubscribeOnlyOnceSingleOperator.java 文件源码项目：reactive-grpc 阅读 30 收藏 0 点赞 0 评论 0

@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);
        }
    };
}

SubscribeOnlyOnceTest.java 文件源码项目：reactive-grpc 阅读 28 收藏 0 点赞 0 评论 0

@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);
}

BookDetailPresenter.java 文件源码项目：NovelReader 阅读 31 收藏 0 点赞 0 评论 0

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();
                }
            });
}

BaseInteractor.java 文件源码项目：CleanArchitecture 阅读 29 收藏 0 点赞 0 评论 0

protected <E> SingleObserver<E> getSingleSubscriber(final RxSingleSubscriberEvents singleSubscriberEvents) {
    return new SingleObserver<E>() {

        @Override
        public void onSubscribe(@NonNull Disposable d) {
            queueSubscriptionForDisposal(d);
        }

        @Override
        public void onSuccess(E value) {
            singleSubscriberEvents.onSuccess(value);
        }

        @Override
        public void onError(Throwable error) {
            singleSubscriberEvents.onError(error);
        }
    };
}

PlayListPresenterImpl.java 文件源码项目：Android-AudioRecorder-App 阅读 48 收藏 0 点赞 0 评论 0

@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());
        }
      });
}

AttachDisposableSingle.java 文件源码项目：DisposableAttach 阅读 38 收藏 0 点赞 0 评论 0

@Override
protected void subscribeActual(SingleObserver<? super T> s) {
    SingleObserver<? super T> observer;
    try {
        observer = ObjectHelper.requireNonNull(s, "Null Observer");
    } catch (Throwable e) {
        Exceptions.throwIfFatal(e);
        // can't call onError because no way to know if a Disposable has been set or not
        // can't call onSubscribe because the call might have set a Disposable already
        RxJavaPlugins.onError(e);

        NullPointerException npe = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
        npe.initCause(e);
        throw npe;
    }

    source.subscribe(new AttachSingleObserver<>(observer, this.compositeDisposable));
}

Network.java 文件源码项目：EasyAndroid 阅读 54 收藏 0 点赞 0 评论 0

public static void getNews(SingleObserver<List<News.ContentBean>> observer)
{
    service.getNews()
           .subscribeOn(Schedulers.newThread())
           .flatMap(new Function<News, Observable<News.ContentBean>>()
           {
               @Override
               public Observable<News.ContentBean> apply(News news) throws Exception
               {
                   L.e();
                   return Observable.fromIterable(news.getT1348647853363());
               }
           })
           .toList()
           .observeOn(AndroidSchedulers.mainThread())
           .subscribe(observer);
}

SingleIfThen.java 文件源码项目：RxConditions 阅读 29 收藏 0 点赞 0 评论 0

@Override
protected void subscribeActual(@NonNull SingleObserver<? super T> observer) {
    boolean b;

    try {
        b = condition.getAsBoolean();
    } catch (Throwable ex) {
        EmptyDisposable.error(ex, observer);
        return;
    }

    if (b) {
        then.subscribe(observer);
    } else {
        orElse.subscribe(observer);
    }
}

SingleObserverExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 34 收藏 0 点赞 0 评论 0

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());
        }
    };
}

FlowableExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 34 收藏 0 点赞 0 评论 0

private SingleObserver<Long> getObserver() {

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

            @Override
            public void onSuccess(Long 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());
            }
        };
    }

SimpleExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 29 收藏 0 点赞 0 评论 0

private void getData() {
    Observable.concat(memory, disk, network)
            .first("")
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new SingleObserver<String>() {
                @Override
                public void onSubscribe(Disposable d) {
                    // TODO: 2017/7/5
                }

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

                @Override
                public void onError(Throwable e) {
                    // TODO: 2017/7/5  
                }
            });
}

ContainsExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 31 收藏 0 点赞 0 评论 0

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

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

        @Override
        public void onSuccess(Boolean 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());
        }
    };
}

SequenceEqualExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 29 收藏 0 点赞 0 评论 0

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

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

        @Override
        public void onSuccess(Boolean 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());
        }
    };
}

AllExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 29 收藏 0 点赞 0 评论 0

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

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

        @Override
        public void onSuccess(Boolean 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());
        }
    };
}

CountExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 29 收藏 0 点赞 0 评论 0

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

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

        @Override
        public void onSuccess(Long 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());
        }

    };
}

MaxExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 26 收藏 0 点赞 0 评论 0

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

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

        @Override
        public void onSuccess(Long 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());
        }

    };
}

FirstExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 34 收藏 0 点赞 0 评论 0

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(" onNext : ");
            textView.append(AppConstant.LINE_SEPARATOR);
            textView.append(" value : " + value);
            textView.append(AppConstant.LINE_SEPARATOR);
            Log.d(TAG, " onNext ");
            Log.d(TAG, " value : " + value);
        }

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

LastExampleActivity.java 文件源码项目：RxJava2-Android-Sample 阅读 29 收藏 0 点赞 0 评论 0

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());
        }
    };
}

RXVertxDaoTestBase.java 文件源码项目：vertx-jooq-async 阅读 34 收藏 0 点赞 0 评论 0

protected <T> SingleObserver<T> failOrCountDownSingleObserver(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 e) {
            fail(e);
        }

    };
}

MemberSingle.java 文件源码项目：rxjava2-jdbc 阅读 34 收藏 0 点赞 0 评论 0

@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> md = new MemberSingleObserver<T>(observer, this);
    observer.onSubscribe(md);
    if (pool.isClosed()) {
        observer.onError(new PoolClosedException());
        return;
    }
    add(md);
    if (md.isDisposed()) {
        remove(md);
    }
    requested.incrementAndGet();
    log.debug("subscribed");
    drain();
}

DBFlowBaseSingle.java 文件源码项目：RxDbflow 阅读 25 收藏 0 点赞 0 评论 0

@Override
protected void subscribeActual(SingleObserver<? super Container> observer) {

    observer.onSubscribe(EmptyDisposable.INSTANCE);
    try {
        Container v =  run();
        if (v != null) {
            observer.onSuccess(v);
        } else {
            observer.onError(new NullPointerException("The callable returned a null value"));
        }
    } catch (Throwable e) {
        Exceptions.throwIfFatal(e);
        observer.onError(e);
    }
}

PermPresenter.java 文件源码项目：AppOpsX 阅读 26 收藏 0 点赞 0 评论 0

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();
        }
      });
}

PermPresenter.java 文件源码项目：AppOpsX 阅读 33 收藏 0 点赞 0 评论 0

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) {

        }
      });
}

AppPermissionActivity.java 文件源码项目：AppOpsX 阅读 47 收藏 0 点赞 0 评论 0

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) {

        }
      });
}

MainActivity.java 文件源码项目：AppOpsX 阅读 31 收藏 0 点赞 0 评论 0

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) {

        }
      });
}