rx-java

0열

1답변

결합 된 목록에서 2 개의 유동성 목록의 변경 사항을 계속 듣고 싶습니다.

나는 유동성 목록이 두 개 있는데이 두 가지를 결합하여 일부 기능을 적용하고 유동성 목록을 얻을 수있다. 초기 유동성 목록은 DB 의 데이터를 나타내며 생각이 바뀌면 결합 목록이 변경 될 수있다. 입력이 변경됩니다. 일단 zip이 제대로 작동하면 zip은 올바른 접근 방식이 아니므로 변경 사항을 계속해서 내 보내지는 않습니다. 나는,이 목록을 결합하여 일부

0열

1답변

우리는 왜 Observer.from()이 필요합니까?

나는 안드로이드에서 RxJava를 배우고 있습니다. 여기이 자습서를 다음입니다 : 아래의 코드와 같이 http://plavatvornica.com/rxjava-for-beginners/ , 난의 OnError 하여 목록에 하나의 항목을 방출이 관측을 만든 나는의 사용의 내 understaning을 deepn하는 질문이 있습니다 RxJava 라이브러리. qu

1열

1답변

메모리 누수를 방지하기 위해 Rx Subscription 및 Observable을 정리하는 방법은 무엇입니까?

저는 Rx Java 구독 및 관측 가능 항목을 자주 사용하는 프로젝트를 진행하고 있으며 개념이 매우 새로워졌습니다. 나는 그 (것)들을 처분하기위한 최선의 방법이 무엇인지 궁금해하고있었습니다. 현재 doOnUnsubscribe() 함수의 구독/관찰 가능 항목을 null로 설정하고 takeUntil()을 PublishSubject과 함께 사용하여 관찰 가능

0열

2답변

이벤트 스트림을 실행하는 작업을 반복하는 적절한 방법

저는 RxJava를 처음 사용합니다. 그래서 저는 여전히 그 문제를 해결하려고합니다. 나는 버튼 클릭의 흐름을 나타내는 Observable을 가지고있다. 그래서 그것은 뜨겁다. 버튼을 클릭 할 때마다 I/O를하고 싶습니다. 실패하면 반복 할 때까지 I/O를 다시 시도하려고합니다. 이것은 retry() 또는 repeat()을 사용할 수있는 좋은 기회 인 것

2열

1답변

.just() 연산자를 사용할 때 지연을 추가하는 방법

아래 코드와 같이 .just() 연산자로 Observable을 코딩했습니다. mAsyncObservable = rx.Observable.create(new rx.Observable.OnSubscribe<Integer>() { @Override public void call(Subscriber<? super Integr> subscrib

1열

1답변

모든 테이블 잘라 내기 - Room

룸 라이브러리의 모든 테이블을 잘라내는 가장 빠른 방법은 무엇입니까? 내 목표는 하나의 RxJava CompletableFromAction을 사용하여 전체 데이터베이스를 지우는 것입니다. 많은 테이블에서 삭제하는 @을 만들 수 있습니까?

5열

2답변

Java 9 Flow Interfaces 사용 방법/Java 9에서 Java 9 Flow Interfaces를 포함시키는 방법은 무엇입니까?

먼저 Reactive Programming에 대한 경험이 많지 않습니다. JDK 9 (Flow and its nested interfaces)에는 인터페이스가 몇 개 밖에 없으므로 JDK 9에는 명백하게 RxJava와 같은 반응 라이브러리가 포함되어 있지 않습니다. Javadoc에는 Publisher, Subscription 및 Subscriber의 임 플

0열

2답변

값 집합을 기반으로 데이터 모델을 업데이트하는 방법

시나리오는 정수 값의 Set을 기반으로하는 목록 내의 데이터 모델을 업데이트하는 것입니다. 예를 들어 ArrayList에 갖는 Student { name: "abc", id: 1, hasPassed: false }... 가 지금은 기본적으로 내부 학생 ID를 가지고 정수의 집합이 {1, 2, ...} 통과 학생 나타내는 학생

0열

1답변

RxJava. Observable/Flowable 스트림의 모든 항목에 가입하십시오.

하나의 웹 페이지에 표시 할 항목을로드 중입니다. 병렬로 항목의 가격을로드하고 있습니다. 간체는 다음과 같습니다. Observable<Integer> ids = itemIdsToShow(); // COLD Observable Observable<Item> items = ids.flatMap(id -> loadingItem(id)); Observable<

0열

1답변

스로틀 RxJava에서

제한 규칙 : 1000MS가 시간 초과 또는 버퍼 사이즈까지 최근 100ms의 방출 다른 항목, 다음 항목이, 그렇지 않으면 즉시 가입자에 제공하지 수신 항목을 버퍼 될 수있는 경우 500에 도달 한 다음 구독자에게 버퍼링 된 항목 목록을 전달하십시오. RxJava가이 작업을 수행 할 수 있습니까?