rx-java

1열

1답변

별도의 스레드에서 HashMap 값 변경 내용을 듣고 Flowable으로 만드는 방법은 무엇입니까?

나는 변경을 듣고 일부 작업 을 만들고 싶어 항목의지도를하고 난 별도의 스레드에서 그것을하고 싶은,하지만 맵은 변경하지만 난 그게 val removedItemList: HashMap<Int,Item> = HashMap() Flowable.fromArray(removedShoppingList.values).subscribeOn(Schedulers.io()

0열

1답변

RxJava 무한 관측 가능 2 무한 완료 체인

무한 관측 대상이 무한 관측 가능하고 무한 관측 대상이 관측 가능 체인이 있습니다. 이처럼 :는 repo.infinitGetItems() .switchMap(items -> Observable .just(items) .flatMap(items -> repo.nonInfinitObs(items))); 내가

2열

1답변

Rx Observable 트랜잭션 내에서 영역 호출을 사용할 때 영역 스레딩 문제를 방지하려면 어떻게해야합니까?

이는 수신 거래 RealmHelperRepo이라고 뷰 모델이다는 HelperRepo 인터페이스 @PerActivity public class RoleSelectionViewModel extends BaseViewModel<RoleSelectionMvvm.View> implements RoleSelectionMvvm.ViewModel { priv

1열

2답변

RxJava : startWith() 기본 앞에 붙이는 방법 부모가 관찰 할 수있는 시간마다 emit을 내 보냅니다. 나의 관찰은 어떤 객체를 생성하는 패턴을 가지고 노력

메신저, 같은 도메인 이벤트로 변환됩니다 시작, 성공, 관찰을 일으키기 주위 emited 오류, 즉 의미 public Observable<BookRenderingEvent> extractAndRenderObservable(String epubPath) { return extractObservable(epubPath) .flatMap

0열

1답변

RX에 맞게 코드가 완료되었습니다. onSubscribe 스레드를 차단하지 않습니다.

새 스레드를 생성하여 네트워킹 작업을 수행하는 기존의 RX 코드가 아닙니다. 작업이 완료되면 콜백에서 하나의 메소드를 호출합니다. 이 코드가 실행되는 스레드를 제어 할 권한이 없습니다. 그것은 유산이며 새로운 Thread을 단독으로 생성합니다. interface Callback { void onSuccess(); } static void ex

0열

1답변

Rx : 관찰하기 위해 N 초 이상 경과해야합니다.

내 앱용 스플래시 화면을 만들고 있습니다. 기본 화면으로 이동하기 전에 N 초 이상 지속되기를 바랍니다. 나는 Rx 변수 myObservable이 서버 또는 로컬 캐시에서 데이터를 반환합니다. myObservable을 N 초에 완료하려면 어떻게해야합니까?? myObservable // .doStuff to make it last at least N sec

0열

2답변

는 RxJava 싱글/I 흥미로운 문제</p> <p>에 직면 한 인터페이스

의 관찰 가능한 리턴 구현 나는 다음과 같은 방법을는 인터페이스 @Override public Single<IResults> getResults() { return Single.just(new ConcreteResults()); } IResults 및 ConcreteResults는 구현이있다. 그러나 나는 오류이 문제를 해결하는 방법 Err

0열

3답변

http 게시 후 응답이 null입니다.

REST API에 대한 HTTP 게시 요청을 보내고 있습니다. 서버에서 상태 확인 응답을 받고 있지만이 스크립트에서는 항상 'myError'기능을 실행합니다. 백엔드에서는 모든 오류없이 정상적으로 실행됩니다. 오류 기능에서도 응답 값은 정의되지 않은 상태로 유지됩니다. var toDoApp = angular.module('toDoApp'); toDoAp

0열

1답변

RxAndroid - 우편 연산자로 오류 처리

요청을 병렬로 처리하고 모든 관찰 가능 항목을 완료 할 때 처리하도록하는 방법을 찾으려합니다. 모든 observables가 응답을 할 때 모든 것이 작동 함에도 불구하고 모든 것이 끝나면 모든 모든 오류를 처리 할 수있는 방법이 없습니다. BiFunction 같은 각 오류가 성공적인 경우에 어떻게 참여하는 메커니즘이 없다는 것이다 이러한 접근 Observa

0열

1답변

일반용 TestScheduler RxJava로 관찰 가능

TestScheduler을 사용하기 시작했습니다. 나는이 대신 사용하는 경우 @Test public void test1() throws Exception { //when TestScheduler scheduler = new TestScheduler(); TestObserver<Long> subscriber = new TestOb