rx-java

0열

1답변

rxJava 시간 초과 유틸리티를 사용할 때 TimeoutException이 발생하지 않습니다.

5 초 내에 텍스트를 입력하지 않으면 TimeoutException이 발생하지 않습니다. 아래 코드 메서드는 getMsg()를 호출하고 텍스트 입력을 기다립니다. 나는 'timeout (5, TimeUnit.SECONDS)'을 추가하여 입력을 위해 5 초 동안 만 기다렸다. 사용자가 5 초 안에 msg를 입력하지 않은 경우 시간 초과 오류를 표시하려고합니다

8열

2답변

RxJava에서 Completable, Single, Maybe 및 Terminating Observables를 처분하는 모범 사례

Android 관점에서 묻지 만 일반적으로 RxJava에 적용해야합니다. 가장 좋은 방법은 내보기에도 항상 짧은 Completable, Single, Maybe 살고 가 짧은 순서로 종료해야 Observable 수신 유형을 종료 폐기해야하지만, 사용자가보기를 닫을 때 여전히 수행 할 수있다? 나는 Rx chain이 종료 될 때, 그것은 폐기되지만 이것은 뷰

0열

1답변

RxAndroid에서 Observer를 생성 할 때 오류가 발생했습니다.

아래 코드와 같이 RxAndroid를 사용하여 예제를 만들고 있습니다. Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> e)

0열

1답변

A 생성자의 반환 값을 상속하는 방법

형식 유추가 원하는대로 수행되지 않는 다음 코드에서 형식 불일치 컴파일러 오류를 수정하고 싶습니다. sealed class Result { data class Success(val logs: List<Log>) : Result() data class Failure(val throwable: Throwable) : Result()

0열

1답변

RxJava : 샘플링하는 방법을 변경하지 않고 반복 할 때

Observable 이 눈에 띄게 될 때마다 Observable x의 가장 최근의 반복 가능한 (!) 값을 항상 내보내는 Observable을 생성하려고합니다. 이후 t 사이의 변경 사항이없는 경우 x의 반복 된 값을 방출하지 않으므로 x.sample(t)을 사용할 수 없습니다.

-1열

1답변

SwipeRefreshLayout에서 RxBinding을 사용하여 깔끔하게하는 방법은 무엇입니까

RxBinding을 제대로 사용하는 방법을 이해하는 데 어려움을 겪고 있습니다. 사용자가 SwipeRefreshLayout을 쓸어 버릴 때 네트워크 요청을하려면 뭔가 말하고 싶습니다. 내가 onStart에 전화 setupSwipeRefresh()라는 함수에 싸여 것을 가지고 있기 때문에 RxSwipeRefreshLayout.refreshes(swipeCon

1열

1답변

왜 개체를 주입하고 io() 스레드에서 API 호출을하면 조각 열기가 느려 집니까?

VacationFragment의 onAttach()에서 VacationViewModel -> VacationRepository, 에서 featuredDays()를 호출하고 있습니다. VacationFragment로 이동하는보기를 클릭하면 알림이 표시되고 지연이 열리 며 몇 밀리 초를 기다립니다. 그것은 VacationFragment를 엽니 다. 내가 vac

0열

1답변

그룹 목록

나는이 다음과 같은 모델이 있습니다 { "account" : { "accountName": "Complete Access", "accountNumber": "062005 1709 5888", "available": 226.76, "balance": 246.76 }, "transactions": [{ "id"

0열

1답변

봄 5 원자로 - 투광 항목마다 내가</p> <pre><code>Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) </code></pre> <p>으로 매 초마다 값을 방출하기 위해 노력하고 있지만 1 초 지연을 시작으로 한 번에 모든 것을 방출되는

일초. 각 요소가 방출 될 때 지연을 어떻게 도입 할 수 있습니까?

1열

1답변

UI 스레드에서 계속 관찰 가능

새 스레드에서 내 RxJava 관찰 가능 항목을 실행하는 데 문제가 있습니다. Scheduler.io()에 압축 DB 쿼리를 실행하려고하지만 관계없이 UI 스레드를 차단합니다. 이유를 모르겠다. DB에 대한 코드 : public void searchKey(String searchTerms, Airport... excluding) { TBDataBa