rx-java

-1열

1답변

RxJava2의 사용자 지정 Observable에서 관찰자의 처분 작업을 알리는 방법

In this thread, 수신 거부 이벤트를 관찰하는 방법에 대한 질문이 있으므로 수신 거부 후 수신기를 정리하고 제거 할 수 있습니다. 그러나 RxJava2에서는 위 스레드가 더 이상 작동하지 않는 메서드입니다. def myObservable = Observable.create({ aEmitter -> val listener = {event

0열

1답변

BLE 장치 writeCharacteristic 실패

BLE 혈압 장치에서 데이터를 가져 오려고합니다. 문서는 기기가 연결될 때마다 날짜/시간을 동기화해야한다고 말합니다. 코드 : interactionSub = Observable.concat( deviceConnection .writeCharacteristic(ReactiveBluetoothHelpers.DATE_TIME_CHARAC

0열

1답변

Single을 사용하고 Rxjava가 추가 장착 요청을 실행하지 않습니까?

안녕하세요 저는 retrofit과 rxjava를 사용하여 간단한 요청을하고 응답을 되 찾았지만 요청 자체를 작성하거나 응답을 되 찾는 것 같지 않습니까? 이 내 개조 코드 : public class Controller public Single<List<ListItems>> getItems() { return apiCall().getItems(

1열

2답변

관찰 가능 항목을 방출하기 전에 코드를 실행할 수있는 방법이 있습니까? (재 시도 목적으로)

관찰 대상을 구독으로 다시 시도하고 싶습니다. 모든 것이 잘되었지만 지금은이 관찰을 다시 시도 할 때마다 몇 가지 코드를 실행하려고합니다. 어떤 제안? observableItem.retry(1).subscribeWith(subscriber);

1열

1답변

Vert.x 이벤트 루프를 사용하여 RxJava 실행을 예약하는 방법

Vert.x 이벤트 루프를 RxJava 실행을위한 스케줄러로 사용할 수 있습니까? VertxScheduler가 Vert.x 이벤트 루프 기반 스케줄러의 일종해야 뭔가 같은 ... Observable.range(1, 10).flatMap(it -> Observable.just(it) ).subscribeOn(new VertxScheduler()).

2열

1답변

RxJava, 처분하지 않으면 어떻게됩니까?

큰 파일을 업로드하려면 내 Android 앱이 지원해야하지만 업로드가 완료 될 때까지 사용자가 기다리지 않기를 바랍니다. 일반적으로 Observable을 사용하면 뷰가 소멸 될 때 dispose()를 호출합니다. 업로드 할 때 어떤 경우에도 완료 될 때까지 처리 할 수 없습니다. 그래서 나는이 좋아하려고 private val compositeDispos

0열

1답변

데이터베이스에 모노를 구독 할 때 일회용품을 보관하십시오.

현재 reactor-core을 탐색 중입니다. Mono를 구독하고 구독자의 실행을 처리 할 수있는 일회용품을 저장할 수 있습니다. Mono<Object> task1 = Mono.just("Task1"); Mono<Object> task2 = Mono.just("Task2"); System.out.println(System.currentTimeMillis

0열

1답변

다른 Completable을 실행 한 후 Completable 목록을 체인화하는 방법

일부 데이터를 데이터베이스에 저장하려고합니다. 메서드를 추가하기 위해 Completable을 사용합니다. 하나의 엔티티 - 고객을 저장 한 후에는 고객의 저장 후에 만 일 목록을 저장하려고합니다. 이것은 지금 내 코드입니다. mDatabaseManager.addCustomer(customer) .observeOn(AndroidSchedul

0열

1답변

RxAndroid/RxLifeCycle - onComplete 대신 onError 처리하기

현재 RxJava으로 네트워킹에 RxLifeCycle을 구현하려고합니다. Consumer의 하위 클래스를 사용했지만 RxLifeCycle의 경우 onError을 처리해야합니다. 그래서 Observer으로 옮겼습니다. 이 문제는 통화가 처리 될 때 onError 대신 onComplete이 호출된다는 것을 의미합니다. buildle.gradle : // RxJ

0열

2답변

Api는 제한된 연결로 Rxjava2 + Retrofit2를 호출합니다.

Retrofit2과 Rxjava을 사용하여 API 호출을하고 있습니다. 여러 API 호출 (동일한 API에 대해)을 수행해야하는데, 그 중 100 개를 호출 해 봅시다. 이제 나는 최대 5 명이 병렬로 실행되기를 원한다. 따라서 API 호출이 5 번 발생하면 여섯 번째 호출이 기다려야합니다. 진행중인 5 회의 통화 중 하나라도 완료되면 여섯 번째 통화가 시