concatmap

0열

1답변

데이터를 보내는 제목이 있습니다. 그런 다음 대기열에서이 데이터를 수정하려고합니다 (긴 작업). 다른 피사체가 내 대기열을 줄이고 자 다른 일을 방출 할 때 PublishSubject<Integer> myBaseSubject = PublishSubject.create(); PublishSubject<Integer> otherSubject = Pub

1열

2답변

Observable concatMap 어떤 이유로 주 스레드에서 일을합니다.

Observables 체인이 있고 모든 작업이 끝난 후 닫히는 대화 상자가 있습니다. 순서는 다음과 같습니다. 1 api 호출 받기 ResponseBody 2 응답 본문 프로세스 가져 오기 (사용자 스레드가 아님) 다른 프로세스 (사용자 스레드가 아님) 첫 번째 호출 중에 대화 상자는 괜찮습니다. 두 번째 호출이 오면 첫 번째 호출의 본문이 수신되고 대화

2열

1답변

방사형이 다른 다수의 관측 값 체인하기

나는 관측 대상물을 함께 연결하는 방법을 찾으려고합니다. 기존 방법이 있습니다 : public static Observable<Data> getData(). doSomeBackgroundWork() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(ne