rx-java2

1열

1답변

복잡한 문제를 해결하기 위해 반응 형 프로그래밍 (RxJava)을 사용해야합니까?

나는 RxJava Observable로서 이벤트 스트림을 표현하기 시작한 어플리케이션을 가지고있다. 이벤트의 요구 사항과 구조는 처음에는 간단 했으므로 RxJava와 함께 제공된 운영자는 필요한 단순 변환에 매우 적합했습니다. 그러나 그 이후로 요구 사항과 비즈니스 논리는 훨씬 더 복잡해졌습니다. 매우 특별한 방법으로 사건을 연관시킬 필요성이 생겼고 Obs

0열

2답변

수 초가 걸릴 때까지 Rx 건너 뛰기

X 초마다 신호를 계속 내보내는 PublishSubject가 있습니다. Y 초 후에 방출되는 첫 번째 항목 만 고려하고 싶습니다. 예 관찰 A는 매초 관찰 B 만 사이에 것들을 무시이 "체크"5 초마다 출사한다 "체크"방출한다. 즉, 일정한 시간이 경과 할 때까지 모든 항목을 건너 뜁니다. 이 원인은 바운스가 발광하지 않고 5초 을 요지 관찰 가능한 원래

0열

2답변

값으로 RxJava를 사용하여 한 행의 이벤트 시퀀스를 필터링하는 방법

이와 같이 rxjava2를 사용하여 이벤트 스트림을 생성합니다. Observable<Integer> observable = booleanPublisher.map(aBoolean -> { if(aBoolean){ return 1; }else{ return 0; } }).buffer(4).map

-2열

1답변

Merge dependent observables

동일한 유형의 데이터를 방출하는 두 개의 Observable이 있습니다. 그러나 둘 다 스캔 조작자가 다른 값을 초기 값으로 내 보낸 마지막 값에 의존합니다. 나는 그들을 합병해야한다. 내 Observable이 다른 값에 의해 트리거되기 때문에 다른 사람을 구독하게 만들 수 없습니다. 나는 주제가 관련되어야한다고 생각하지만 어떻게 확신 할 수 없다. val

1열

1답변

RxAndroid 2.0.1 subscribe 메서드는 변수를 설정하지 않습니다.

저는 Android 및 반응 프로그래밍에 상당히 익숙하며 지난 이틀 동안 서버에서 게시물을 가져 와서 게시물에로드하는 활동을 시도했습니다 [ ] 내 애플 리케이션에서 나중에 사용됩니다. 여기서 문제는 그 Post []를 displayPostsMethod에 전달할 때 null이라는 것입니다. 여기에 활동 public class HomeActivity exte

0열

1답변

RxJava 2 : Observable.create() 비동기 코드가 Thread.sleep()을 사용하여 종료 될 때까지 대기

Observable.create(...)을 사용하여 일부 비동기 코드를 래핑합니다. 비동기 코드는 5 초 동안 "활성"상태 여야하며 중지해야합니다. Observable.<MyObject>create(emitter -> { // Some async code emitter.setDisposable(Disposables.fromRunnabl

0열

2답변

싱글에서 방출 한 값을 어떻게 메모합니까?

개체를 만드는 값 비싼 계산이 있다고 가정 해보십시오. 발신자에게 어디에서 그런 유연성이 있는지 알려주고 싶습니다. subscribeOn(). 그러나 부작용 (예 : 개체가 일부 외부 데이터 저장소에 의해 뒷받침 됨) 때문에 계산을 두 번 이상하고 싶지 않습니다. 나는 MyObject myObject = MyObject.createExpensively(pa

1열

1답변

retrofit2 rxjava2 전 세계적으로 네트워크 예외를 처리하고 자동 인증

다음 처리 오류 코드가 있습니다. 이 코드는 오류 처리에 완벽하게 작동하지만 "승인되지 않은"오류를 처리하려고합니다. 오류 코드가 "권한이 없습니다"때 public class RxErrorHandlingCallAdapterFactory extends CallAdapter.Factory { private RxJava2CallAdapterFactor

1열

1답변

RxJava2

에서 저장소 패턴은 로컬 및 원격에서 Repository 패턴 및 로딩을 사용하는 경우, 그것은 의미가 RxJava2의 로컬 반환 Maybe<T> 및 원격 수익 Single<T>을 할 수 있도록합니까?

0열

1답변

RxJava Firebase를 원격 데이터 소스로 구현하는 방법에 대한 지침이 필요합니다.

저는 RxJava의 초보자이며 일반적으로 MVP 구조입니다. 나는 Firebase RTDB를 전통적인 방식으로 사용하여 더 많은 경험을 가지고 있으며, 이제 RemoteDataSource (예 : TaskRemoteDataSource)로 가장 잘 적응시키는 방법을 궁금해합니다. 다른 MVP 예제에서는 callback.onTaskLoaded (task)를 사