rx-java

0열

1답변

수천 개의 원소를 방출하는 블로킹 장시간 관찰 가능 원소에 의해 방금 방출 된 원소를 알고 싶습니다. 아래 코드는 작동하지만 range()에서 오는 거대한 버퍼를 만듭니다. sourceOservable .zipWith(Observable.range(0, Integer.MAX_VALUE), (any, counter) -> counter) .whatever

1열

2답변

Observable이 완료 될 때까지 스레드를 잠그는 방법

나는 이벤트를 보내려는 시나리오를 테스트하고 있는데, 소비자가 흐름을 계속하기 위해 처리를 마칠 때를 관찰합니다. 즉 이벤트를 트리거 할 때 필요합니다. rxJava를 사용하여 소비자 프로세싱이 끝날 때까지 주 스레드를 차단해야합니다. Observable을 사용하여 관찰 가능한 결과를 기다리는 주 스레드를 잠그지 못했습니다. 내 생산 @Service pu

2열

2답변

이

먼저 요청, 내 상황을 설명하자 : 내가 API를 통해 새 레코드를 등록 할 . API를 통해 일부 행을 업데이트하려고합니다. 이러한 모든 요청이 종료되면 알림을 받아야 다른 작업을 시작할 수 있습니다. 은 특히 나는이 두 ArrayList : 각 보고서 내 ApiService에서 Observable 인스턴스를 얻는 방법을 사용할 수 있습니다 ArrayLi

3열

1답변

RXJava2. 나는 한 번 방출하는 시내를 처분 할 필요가 있는가? (싱글, 아마)

나는이 문서에서 알 수있는 바와 같이 이러한 Disposable disp = Single.fromCallable(()-> loadData()) .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) .subscribe(res-> showInUI(

12열

1답변

실패한 해결 방법 : Lcom/google/devtools/build/android/desugar/runtime/ThrowableExtension;

AndroidStudio의 최신 미리보기에서 Retrofit으로 RxJava를 사용하고 있습니다. 내 프로젝트는 1.8 suport는 다음과 같이 활성화 자바 있습니다 compileOptions { targetCompatibility 1.8 sourceCompatibility 1.8 } 그러나 코드를 컴파일하고 실행 나는 내가 onE

0열

3답변

안드로이드 프로젝트에서 리 액티브 프로그래밍으로 Junit하기

나는 RxAndroid/RxJava를 사용하는 안드로이드 프로젝트에서 JUnit4를 사용하려고합니다. 나는 개조 호출 (지금은 하나에 불과)에 대한 UUIDApi.java 단지 인터페이스 public interface UUIDApi { static final String BASE_URL = "https://www.uuidgenerator.net"

0열

1답변

일련의 연결 연산자 뒤에 인수를 유지 RxJava

연산자의 첫 번째 인수에 액세스 할 수 있습니까? 나는 지퍼 연산자를 사용하여 값을 보존하려고하지만 그것을 처리하지 못했습니다. 당신은 중첩을 통해 업스트림 인수를 보존 할 수있는 도움 .concatMap(this::getDeviceStatus) .concatMap(this::getCertificateResponse) .conc

1열

1답변

RxJava - Looper.prepare()를 호출하지 않은 스레드에서 핸들러를 생성 할 수 없음 - API 16

전체 공개, RxJava를 배우고 있습니다. 사용할 수있는 자습서가 많지 않다면 아이디어를 이해하기가 약간 어렵습니다. 초보자 친화적 인. 이 오류는 API 16에서 발생하며 위의 API 23 & (아래 테스트 됨)에서 정상적으로 작동합니다. 알 수 있듯이 비동기 작업을 RxJava로 대체하려고합니다. private void getGps() { T

7열

1답변

vert.x와 RxJava의 차이

우리는 우리 프로젝트 중 하나의 반응 형 프로그래밍 프레임 워크를 평가하고 있습니다. 방금 vert.x 튜토리얼을 살펴 보았습니다. RxJava 프리젠 테이션을 조금 확인했습니다. RxJava는 CompletableFuture에 더 가깝게 보였다. 그러나 기본 패턴에도 불구하고 RxJava와 Vert.x는 비 차단 프로그래밍에 대한 액세스를 제공합니다. 나

0열

2답변

Android. 회전 할 때 관찰 가능 비트 맵 작성시 OutOfMemory 오류가 발생했습니다.

활동이 imageView입니다. 장치 onCreate을 회전하면 백그라운드 스레드 내부에서 비트 맵 생성이 시작됩니다. 여러 회전 후 나는 비트 맵 생성에 OutOfMemoryError을 가지고있다. 이 문제를 해결하는 올바른 방법은 무엇입니까? weak references에 대한 결정이 있습니까? 여기 내 코드입니다 : public class ImageA