rx-java

0열

2답변

groupBy 작업을 실행 한 후 여러 객체를 단일 객체로 병합하는 방법은 무엇입니까?

나는 의심의 여지를 나타 내기 위해 내가 만든 클래스를 아래에 가지고있다. 내 유동성에 초기 변환을 수행 한 후 내가 가진 : UserScoreTO{id=1, name='john', score=4} UserScoreTO{id=1, name='john', score=5} UserScoreTO{id=1, name='john', score=1} UserSc

0열

1답변

RxJava 더 긴 시간 간격 기간은 현재 방출 숫자에 따라 다릅니다.

Observable 시간 간격이 있다고 가정합니다. Long 항목을 1 초마다 방출합니다. 현재 배출량과 관련하여 해당 기간을 확대하는 방법은 무엇입니까? 예를 들어 처음 4 회의 배출의 경우 매초마다 항목을 방출해야하지만 이후에는 매 3 초마다 항목을 방출해야합니까? 이것은 가능한가요?

0열

1답변

Flowable of Single의 <User>을 Flowable of List로 변환 <User>

UserScoreTO 목록을 단일 사용자 개체 (다 대일 관계)로 그룹화하는 데 사용 된이 Rx Stream을 보유하고 있습니다. public void execute() { getUsers() .flatMap(list -> Flowable.fromIterable(list)) .groupBy(userScoreTO -> use

0열

1답변

완성 된 동적 목록을위한 단일 onComplete 만들기

나는 RxJava로 Firebase 트랜잭션을 래핑하기 위해 this 라이브러리를 사용하고 있습니다. 저는 RxJava를 처음 사용합니다. 그래서 이것은 주로 어떻게 사용하는지에 관한 질문입니다. 시나리오 : Person s와 Label 사이에는 다 대다 관계가 있습니다. Person은 복수 Label을 가질 수 있고, Label은 많은 Person에 주어

3열

1답변

RxJava : 목록에서 요소 제거

map, concatMap, all을 사용하여 객체를 반복하는 데 여러 연산자를 사용했지만 내 목록에서 요소를 제거 할 수 없습니다. Observable.fromIterable(selectedJobs) .observeOn(AndroidSchedulers.mainThread()) // Added this from one answer in SO.

-1열

1답변

RxJava : 간단한 비동기 작업의 차이점 이해

RxJava를 배우고있어 RxJava의 작동 방식에 대한 오해에 불과하다고 생각되는 사소한 문제가 발생했습니다. 간단한 코드 인 Observable과 Consumer 쌍을 보여주는 두 개의 코드 블록이 있습니다. 여기에서 Observable은 1에서 4 사이의 정수로 카운트 스트림을 내보내고 각 사이에는 1 초의 지연이 있습니다. 스 니펫는 - 제대로 동작

-1열

1답변

rxjava1 android (java)를 사용하여 검색 필터

나는 목록이있어 검색 필터가 있습니다. EditText 리스너를 사용하고 for 루프를 사용했습니다. 하지만 난 여기에 내가 AndroidRx과 검색에 사용한 코드의 조각 필터가 rxjava @Override public void onTextChanged(CharSequence charSequence, int i, int i1, int i2) {

1열

1답변

Kotlin에서 RxJava로 데이터 변환

나는 Kotlin을 사용하고 있으며 Observable<List<FlickPhoto>> 모델이 있습니다. 각 FlickrPhoto에는 목록이 포함되어 있고 각 Photos 모델에는 List<Photo>이 포함되어 있습니다. 나는 적은 데이터 또 다른 모델은 기본적으로 인하는 List<PhotoEntity>에 List<FlickrPhoto>을 변환하고, (마

0열

1답변

유닛 테스트에서 RxJava2 Observable이 결과를 표기하기 전에 끝내기를 기다리는 방법

콜드 관측 가능 이벤트에 가입 한 코드 일부를 테스트하려고합니다. 내 문제는 단위 테스트가 내부 관찰 가능 호출이 결과를 주장하기 전에 끝나기를 기다리지 않기 때문에 테스트가 실패한다는 것입니다. 여기 내가 테스트 할 코드입니다 : public class UserManager { private UserRepository userRepository

0열

1답변

RxJava로 루프

이 오브젝트 데이터에는 String 유형의 데이터, ArrayList 유형의 데이터가 포함됩니다. Flowable.just(rxjava.list1).concatMap(new Function<ArrayList<Data>, Publisher<Data>>() { @Override public Publisher<Data> apply(Arr