rx-android

1열

3답변

RxJava 2에서 onComplete() 직전에 코드를 실행 하시겠습니까?

RxLifecycle 처분하기 전에 관찰 가능 상태로 소켓 연결을 닫아야합니다. 어떻게해야합니까?

1열

1답변

rx-java2 Schedulers.io() 강철 mainThread에서 메서드를 호출합니다

방 Rx 방법을 사용하여 데이터베이스에서 데이터를 검색하려고합니다. 이것은 내가 항상 override fun onStart() { super.onStart() disposable.add(presenter.getAllBooks() .subscribeOn(Schedulers.io()) .observeOn(Andro

0열

2답변

groupBy 작업을 실행 한 후 여러 객체를 단일 객체로 병합하는 방법은 무엇입니까?

나는 의심의 여지를 나타 내기 위해 내가 만든 클래스를 아래에 가지고있다. 내 유동성에 초기 변환을 수행 한 후 내가 가진 : UserScoreTO{id=1, name='john', score=4} UserScoreTO{id=1, name='john', score=5} UserScoreTO{id=1, name='john', score=1} UserSc

0열

2답변

Retrofit2 + RxAndroid 루프에서 많은 요청을 실행합니다.

저는 RxAndroid 라이브러리 + Retrofit2를 사용합니다. 내가 2 개 POST 요청 유무 : 모든 카테고리 받기 (귀국일 목록 == 각각의 문자열 카테고리 ID입니다) 내가 모든 제품을로드 할 필요 ProductsByCategory (목록을 반환) 가져 오기 App 시작 후 DB에 저장합니다. 내가 MainFragment을 만들 때 나는 모든

0열

1답변

Retrofit2 10 보낼 개의 다른 매개 변수를 사용하여 요청을 동일 반환 한 응답

나는 방법이 있습니다 ONE reault 반환 Observable<ProductsResponse> products = restApiFactory.getProductService().getProducts(CategoryID) 이 어떻게 다른 ID 10 요청을 할 수 있습니다 : for(int i = 0; i< 10; i++){ Observable<Pro

0열

1답변

완성 된 동적 목록을위한 단일 onComplete 만들기

나는 RxJava로 Firebase 트랜잭션을 래핑하기 위해 this 라이브러리를 사용하고 있습니다. 저는 RxJava를 처음 사용합니다. 그래서 이것은 주로 어떻게 사용하는지에 관한 질문입니다. 시나리오 : Person s와 Label 사이에는 다 대다 관계가 있습니다. Person은 복수 Label을 가질 수 있고, Label은 많은 Person에 주어

-4열

1답변

rxjava2 : 연결 완료 결과를 사용하여 IO 스레드에서 관찰하기

처음에는 네트워크 작업을 주 스레드에서 호출해서는 안됩니다. 그게 내가 Schedulers.io()에 completables를 관찰하는 이유입니다! 나는 두 개의 연결을 연결하려고합니다. 모두 completable 사용 네트워크, 왜 내가 Schedulers.io()에 가입 thats. concatWith (또는 andThen) 코드를 사용하는 경우 Net

-1열

1답변

rxjava1 android (java)를 사용하여 검색 필터

나는 목록이있어 검색 필터가 있습니다. EditText 리스너를 사용하고 for 루프를 사용했습니다. 하지만 난 여기에 내가 AndroidRx과 검색에 사용한 코드의 조각 필터가 rxjava @Override public void onTextChanged(CharSequence charSequence, int i, int i1, int i2) {

1열

1답변

Obersable의 변경 가능 목록 <Object> 모두 완료되어 목록으로 결합 될 때까지 기다려주십시오. <Object>

저는 RxJava/RxAndroid의 전문가가 아니며이 시나리오에 몇 가지 문제가 있습니다. 기본적으로 크기를 알 수없는 관찰 가능 목록을 변경할 수 있으며 모든 항목이 완료 될 때까지 기다리고 싶습니다. var observableList: MutableList<Observable<Object>> = mutableListOf() 그리고 나는 같은 것을

-1열

2답변

PublishSubject를 사용하여 RxAndroid의 구독을 구독 취소하는 대신 연결을 해제하는 목적은 무엇입니까?

저는 블루투스 통신을 위해 RxAndroidBle을 사용하는 블루투스 프로젝트를 진행하고 있습니다. 나는 구독이 정리되는 두 가지 다른 방법을 발견했습니다. 나는 누군가가 차이점과 혜택을 설명 할 수 있는지 궁금해했다. 두 가지 예는 다음과 같습니다. 첫째 : https://github.com/Polidea/RxAndroidBle/blob/master/sa