rx-java2

0열

1답변

사용자 정의 버튼을 만들었습니다. 내부 체크 리스너가있어서 PublishSubject의 도움을 받아 observable로 노출합니다. 제 UI에서 public class SwitchItem extends LinearLayout implements SwitchButton.OnCheckedChangeListener { //other fields ...

0열

1답변

tracing specifeczipped Rxjava zip operator를 사용할 때 관찰 가능한 오류

Rxjava zip operator를 사용하는 경우, 4 개의 다른 네트워크 호출을 압축한다고 가정 해 봅시다. 예를 들어 : Observable.zip(networkCall1, networkCall2, networkCall3, networkCall4), (model1, model2, model3, model4) -> Mapper.getResult(mo

1열

1답변

플로어 블이 삽입시 데이터를 내 보내지 않습니다.

룸에서 Flowable이 어떻게 작동하는지 이해하는 데 어려움이 있습니다. 나는 getSites()에 의해 반환 내가 전화 할 때마다 upsert 가입자 Flowable에 객체가 항상 호출 될 것으로 예상이 @Insert(onConflict = OnConflictStrategy.REPLACE) void upsert(List<Site> sites); @

0열

1답변

RxJava : 다중 단계 작업을 랩핑하여 단계 완료를 옵저버에게 반환하려면 어떻게해야합니까?</p> <pre><code>Single<LoginResponse> login(); Single<UserData> userData(); </code></pre> <p>내가 다음 <code>userData()</code><code>login()</code>를 호출 할 필요가 :

내가 HTTP 호출을 나타내는, 로그인 및 사용자 데이터 방법이 있다고 할 수 있습니다. 두 가지 모두 성공하면 사용자가 로그인 한 것입니다. Completable : Completable performLogin() { login().doOnSuccess(this::storeLoginResponse) .flatMap(userData())

0열

1답변

stream1을 구독하는 .zip (stream1, stream2, BiFun)은 stream2가 stream1을 기반으로하는 경우 어떻게해야합니까?

일부 복잡한 데이터가있는 Android의 firebase를 사용하고 있습니다. 참조를 저장해야하고 우편 번호 작업이나 RX 전체를 처리하는 방식에 문제가 있습니다. 특정 B에 대한 정보가있는 A object을 새로 만들고 B object에 A에 대한 정보가 업데이트되도록하고 싶습니다. 중포 기지 작업이 모두 성공적이었다 때 나는 로그 캣을 통과 할 때 Si

0열

1답변

gson을 사용하여 json 배열을 모델로 역 직렬화하는 올바른 방법, 개장

http 응답 (모델에서 가져온 것)을 모델로 역 직렬화하기 위해 gson을 사용합니다. 그래서, 지금은이 같은 응답으로 일부 JSON 배열을 가지고 : [{"object":"value"},{"object":"value"},{"object":"value"},{"object":"value"}] rxjava 및 개조를 결합하여, 내가 HTTP 요청을 아래

0열

1답변

수신 + 개조 + 룸 - 싱글 및 유동성

을 결합 나는 다음과 같은 문제가 있습니다 내가 개조를 사용하여 단일 <> 요청을 얻고 유동성 <> (실)와 결합 할 필요가 있습니다. 모두 완료되면 UI에 데이터를 표시합니다. 그리고 룸에서 지속적인 업데이트를 받고 싶습니다. 나는 이것을하기위한 일반적인 방법이기 때문에 zip 연산자를 사용해 보았지만 zip과 관련된 문제는 두 소스의 데이터를 기다리는

1열

1답변

Observable not repeating

관찰 할 수있는 작업을 repeat()에 시도하고 있지만 한 번 이상 수행하지 않습니다. Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> e) throws Exception {

0열

1답변

RxJava2의 "unsafeSubscribe()"연산자는 어떻게 되었습니까?

https://rxjava-doc.readthedocs.io/en/latest/What%27s-different-in-2.0/에는 언급이 없으므로 코딩하는 동안 제안 사항을 볼 수 없습니다. 그래도 "safeSubscribe()"를 볼 수 있습니다. 제거 되었습니까?

0열

1답변

Observable이 다음 활동에서 돌아온 후에 구독하지 않았습니다.

onActivityCreated의 조각에 CompositeSubscription이 있습니다. EditText에서 문자열을 변경 한 후 mViewModel의 코드가 Observable을 방출합니다. 내가 Activityfragment를 시작하면 내 mViewModel에서 mSubscription = new CompositeSubscription();