rx-java2

0열

1답변

문제가 있습니다. 응답을 반환하는 로그인 프로세스를 만들고 있습니다. 로그인이 맞으면 다음과 같은 응답을 보냅니다. { "error": false, "message": "Logged In Successfully", "user": { "username": "administrator", "email": "[email pr

3열

2답변

RxJava zipWith Android Studio 3.0을 사용하는 Kotlin의 IDE 오류

몇 가지 항목을 방출하는 Observable과 Interval Observable을 가진 Observable 목록을 포함하여 첫 번째 관찰 가능 항목이 약간의 시간 지연으로 방출 될 수 있도록 만들고 싶습니다. 가 여기 내 구현 : 일부 항목을 fun populateJust1() { just1.add(SomeClass1("23", 23)) just1.a

0열

1답변

RxJava API 호출이 성공했을 때만 캐시를 호출하려고합니다.

저는 RxJava를 처음 사용하기 때문에이 사용 사례에 대한 해결책을 찾아 낼 수 없습니다. 나는 이것을 2 일 동안 연구했고 지금은 행운이 없다. 나는 내가 먼저 원격 서버에 사용자 데이터를 저장하는 전화 내 응용 프로그램에서 사용자를 등록하는 2 단식, 원격 및 캐시를 가지고 있고, 성공적으로 저장 표시하기 위해 사용자 지정 코드를 반환합니다. 내가 리

1열

1답변

하나만 변경하고 다른 것에서 최신 버전을 얻는 경우에만

다음 예제가 예상대로 작동하지 않아서 zip 및 combineLatest을 사용하고 아래에 표시된대로 withLatestFrom을 사용하려고 시도했지만 예상 출력을 제공하지 못했습니다. @Test fun thereCanBeOnlyOne() { val s1 = BehaviorSubject.create<Int>() val s2 = Behav

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

3열

1답변

어떻게 <strong>RxJava 및 <strong>코 틀린</strong>에</strong> 환장을 사용하여 호출 API에 대한 제네릭 클래스를 만드는 코 틀린

를 사용 RxJava 및 개조? 내 자바 구현 먼저 추가 Gradle을 종속성에서 :: 과 같습니다 // 개조를위한 (사용 가능한 경우 최신 버전으로 업데이트) 구현 'com.squareup.retrofit2 : 갱신 : 2.3.0 ' 구현'com.squareup.retrofit2 : 컨버터 GSON : 2.3.0 ' 인터셉터 구현을위한 16, // 'co

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

1열

2답변

RxJava 2에서 TestObserver를 사용하여 개체 목록을 단위 테스트하는 방법?

다음은 사람 개체를 보유하는 사람 클래스입니다. 비교를 위해 Comparable 구현이 있습니다. 여기 public class Person implements Comparable<Person> { private String firstName = ""; private String lastName = ""; public Perso

3열

1답변

RxJava : 목록에서 요소 제거

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