rx-java

0열

1답변

Activity.runOnUiThread()이 있습니다 if (Thread.currentThread() != mUiThread) { mHandler.post(action); } else { action.run(); } 그것은 의미, 그것은 내가 아니라고하면 핸들러 UI 스레드 및 게시물 행동에 나는 경우 즉시 조치를 실행합니다. 이

0열

1답변

방목 테이블에 Observable 변수를 저장하는 방법이 있습니까?

방 라이브러리를 사용하여 응용 프로그램의 데이터를 저장하고 검색하고 있습니다. 모델 클래스 사용자에는 Observable 등의 변수가 있습니다. Observable은 RxJava 클래스입니다. 하지만 지금은 gradle 빌드가 실패했습니다 - 오류 : 데이터베이스에이 필드를 저장하는 방법을 알아낼 수 없습니다. 당신은 그것에 대한 타입 변환기를 추가하는 것

0열

1답변

Firebase의 android sdk async가 맞습니까?

멍청한 질문이지만 Firebase의 android SDK가 이미 비동기입니까? 이전 프로젝트에서 RxJava를 사용했고 Firebase SDK와 함께 사용하는 사람들의 인스턴스를 발견했습니다. sdk가 이미 비동기이면이 작업이 필요한 이유는 무엇입니까? 감사.

1열

3답변

RxJava의 스캔 연산자가 여러 구독자간에 상태를 유지할 수 있습니까

나는 observeable을 scan 연산자로 변환하므로 항상 현재 값과 이전 값 (또는 초기 값)을 기준으로 값을 방출합니다. Subject<String> subject = PublishSubject.create(); Observable<String> observable = subject.scan("zero", (a, b) -> a + ", " + b)

0열

2답변

RxJava - 과목 사용

RxJava 세계에서 과목 사용은 일반적으로 권장하지 않습니다. Im은 피사체로 쉽게 얻을 수있는 피사체의 속성 변화를 관찰하려고합니다. 나는 rx.net이 Observable.FromEvent()를 제공하여이 상황을 쉽게 처리 할 수 있다는 것을 알고 있지만, 이들이 비 주제 기반 Java 대안인지 궁금해하고있었습니다.

0열

2답변

<p></p> 다음 나는 영역 쿼리의 결과 매핑을 소비하는 시간을 수행해야, 다른 스레드

나는 영역 쿼리를 실행하는 작업을 수행, 그 결과는 작업자 스레드에서 수행해야합니다. 마지막으로 주 스레드에서 결과가 필요합니다 (UI를 업데이트하기 때문에). 그러나 다음 코드 (당연히)는 나에게 예외를 제공합니다. "잘못된 스레드에서 영역 액세스. 영역 객체는 작성된 스레드에서만 액세스 할 수 있습니다." val defaultInstance = Real

0열

1답변

RxJava 간단한 데모가 작동하지 않습니다.

방금 RxJava를 배웠고 매우 유용하다는 것을 알았지 만, 일부 코드를 직접 테스트하기 시작하면 제대로 작동하지 않습니다. 나는 이런 식으로 코드를 작성하지만 아무 것도 인쇄하지 않습니다. 프로그램은 시작 직후에 중지됩니다. public static void main(String[] args) { Observable.just(1, 2, 3,

0열

2답변

RxJava2에서 재시도 연산자를 사용하여 상태를 기억하는 방법

중단을 재개 할 수있는 네트워크 클라이언트가 있지만 재 시도가있을 때 마지막 메시지가 필요합니다. 코 틀린에 예 : fun requestOrResume(last: Message? = null): Flowable<Message> = Flowable.create({ emitter -> val connection = if (last != nu

0열

1답변

왜 RxJava2 doOnSubscribe가 혼란스러운 순서로 실행됩니까? 코드를 인쇄 한 다음

, 2 Observable.just(1) .doOnSubscribe(d -> System.out.println(1)) .doOnSubscribe(d -> System.out.println(2)) .blockingSubscribe(); 그리고이 인쇄 2, RxJava1에서 1 Observable.just(1) .doOn

0열

1답변

Dropwizard @UnitOfWork 비동기 데이터베이스 호출

이것이 일반적인 문제라고 생각하지만 일부 검색 후에 관련 항목을 찾을 수 없었습니다. 내가 겪고있는 문제는 @UnitOfWork과 내 리소스 메서드에 주석을 달고 비동기 DAO 호출을 만드는 내 리소스 메서드 내부에 No Hibernate Session bound to thread 예외가 발생한다는 것입니다. 이 디자인의 배경은 분리 된 I/O 스레드에서