에 따라 서로 다른 길을 나는 다음과 같은 코드가 다음 parentsRepository 내 영역 데이터베이스를 wraping의 repo입니다 Single<Response<User>> single = service.registerUser();
single
.subscribeOn(Schedulers.io())
.observeOn(Sched
현재 reactor-core을 탐색 중입니다. Mono를 구독하고 구독자의 실행을 처리 할 수있는 일회용품을 저장할 수 있습니다. Mono<Object> task1 = Mono.just("Task1");
Mono<Object> task2 = Mono.just("Task2");
System.out.println(System.currentTimeMillis
전화 연락처 목록 데이터베이스에서 연락처 가져 오기를 분할해야합니다. 사용자가 많은 연락처를로드하는 경우 몇 초 동안 멈추지 않아 매우 좋지 않은 것을로드합니다. 나는 Rx로 나누어서 한 번에 20 개의 컨택트를로드하려고하지만, 지연로드가 아니라 시작시 모든 컨택트를로드하는 것으로합니다. 이 순간 나는 concat과 observables의 당겨와 함께 노력
Retrofit2과 Rxjava을 사용하여 API 호출을하고 있습니다. 여러 API 호출 (동일한 API에 대해)을 수행해야하는데, 그 중 100 개를 호출 해 봅시다. 이제 나는 최대 5 명이 병렬로 실행되기를 원한다. 따라서 API 호출이 5 번 발생하면 여섯 번째 호출이 기다려야합니다. 진행중인 5 회의 통화 중 하나라도 완료되면 여섯 번째 통화가 시
다른 서비스에서 일부 데이터를 가져온 후에 실행할 논리가 있습니다. 그 중 하나 또는 모두의 실패를 어떻게 처리합니까? 나는 오류를 기록하고 예외 // Step 1
Observable<Provider> providerObservable = providerService.getProvider(data).toObservable()
.onErro
Single<Something>을 반환하는 Repository 클래스를 만들고 싶습니다. 클래스가 처음 Maybe<Something>를 반환하는 Cache 살펴보고 Maybe 만약 내가 JavaDoc을 통해 검색 한 Single<Something> interface Cache {
fun getSomething(): Maybe<Something>
다음 2 개의 asynctasks를 rxjava로 변환하려고 시도하고 있지만 어떻게해야하는지 잘 모릅니다. 어떤 아이디어? : new AsyncTask<Void, Void, Void>() {
@Override
protected Void doInBackground(Void... params) {
/* Shutdo
Observable에 더 많은 데이터를 생성하라는 신호를 보내는 방법이 있습니까? 저는 10 개의 항목을 생성하는 버퍼링 Observable을 가지고 있으며, 원하는 경우에만 더 많은 항목을 계속 생성하고 싶습니다. 구체적으로 말하면, 무한 스크롤링 Recycler View가 있습니다. 끝까지 스크롤을 계속할 때만 더 많은 항목을 생성하고 싶습니다.
Rxjava2에 내 AsyncTask 코드를 변환하려고했지만 분명히 Rxjava2은 null 값을 처리하지 않으므로 내 응용 프로그램이 충돌합니다. new AsyncTask<Void, Void, Void>() {
@Override
protected Void doInBackground(Void... params) {
S
Observable의 각 항목의 유효성을 검사하고 조건이 실패하면 오류를 반환하는 방법은 무엇입니까? 은 지금은 내부 if와 switchMap를 사용하고 있지만,이 솔루션은 매우 좋은하지 같습니다 Observable.just(1, 2, 3, -1, 4)
.switchMap(x -> {
if (x >= 0) {
return O