rx-java

0열

1답변

내가이 매우 간단한 RxJava 예,이 결과를 제공 List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5)); Observable.fromIterable(arrayIntegers).map(i -> { Log.d("RxJava", "map i = " + i);

0열

1답변

N 요청이 완료 될 때까지 X 요청을 병렬로 실행합니다.

주어진 사용 사례에 적절한 구조를 찾는 데 문제가 있습니다. 주어진 입력 문자열에 대해 Single<String>을 생성하는 기능이 있습니다. 이 Single은 최대 30 분이 소요될 것으로 예상되는 여러 작업의 조합이지만이 질문과 관련이 없다고 생각합니다. 내가 달성하고자하는 동작은 5 개의 작업을 N 개의 작업을 완료하는 목표와 동시에 활성화하는 것입니

0열

1답변

다중 호출을 피하는 공통 관찰 가능을 만듭니다.

메시지를 읽거나 쓰는 방법이 있습니다. fun sendMessage(message: String): Observable<MESSAGE> { return readMessage().doOnSubscribe { socket.write(message) } } readMessage()는 스트림 (socket.read())에서 뜨

1열

1답변

이 경우 DisposableObserver 처리가 중요합니다.

깨끗한 아키텍처로 안드로이드 프로젝트를 작업하고 있습니다.이 public abstract class RxBaseInteractor<T, Params> { private final CompositeDisposable disposables; public RxBaseInteractor() { this.disposables = new

0열

1답변

RxJava, 두 개의 관측 값 결합 및 두 번째 관측 가능 방출

N1과 N2의 두 가지 네트워크 요청을하고 있습니다. 이들은 서로 의존하지 않는 두 개의 개별 요청입니다. 나는 모두의 반응을 얻으면, 나는 장르 목록에서 각각 현재 게임중인 영화의 장르로 설정 장르를 찾을 필요가 Observable<NowPlayingMoviesListResponse> nowPlayingMoviesListResponseObservable

1열

1답변

RxJava 비동기 스레드 구현을 통한 경쟁 조건 방지

스프링 프레임 워크 StringRedisTemplate을 사용하여 여러 스레드에서 발생하는 항목을 업데이트하고 있습니다. public void processSubmission(final String key, final Map<String, String> submissionDTO) { final String hashKey = String.valueO

0열

1답변

RxJava를 사용하여 여러 구독자 및 데이터 흐름을위한 전략 2

RxJava2을 사용하여 올바르게이 작업을 구현하는 방법을 결정할 수 없습니다. 문제는 다음과 같습니다. AuidoRecord을 사용하여 오디오를 녹음합니다. 당신은 내가 수동으로 목록에 가입자를 추가하고 볼 수 있듯이 현재 그 private class StreamAudioRecordRunnable extends Flowable<short[]> implem

0열

1답변

방법

코드 내부에 임시 관찰 가능한 만들기 : static void readCharacteristic(RxBleDevice device, UUID characteristic, Action1<byte[]> callback) { Observable<RxBleConnection> deviceConnObservable = getSharedConnectionOb

0열

1답변

ObservableField 값 변경 내용이 적용되지 않음

mvvm 및 rxbinding을 처음 사용합니다. RxJava와 DataBinding을 사용하여 안드로이드 컨텍스트에서 내 ViewModel을 완전히 분리하려고합니다. ViewModel의 일부 코드 (예 : 폼 유효성 검사)를 단위 테스트하면 ObservableFields가 값을 변경하지 않고 값이 null로 유지됩니다. 내 뷰 모델의 최소 예 : 후 @T

0열

1답변

스플래시 데이터를 미리 가져 오기

피드 앱을 구현하려고합니다. 네트워크에 Splash Activity (피드 네트워크 호출 완료 여부와 상관없이)를 최대 3 초 동안 실행 한 다음 피드가 사용자에게 표시 될 수있는 홈 화면으로 이동하도록 새로운 피드를 호출하려고합니다. 나는 스플래시에서 한 전화의 응답을 내 홈 활동으로 되돌리고 싶습니다. Retrofit with RxJava를 사용하여 네