rx-kotlin

0열

1답변

RxJava 스트림 중간에서 비동기 작업을 조건부로 추가하려면 어떻게해야합니까?

여기, 내가 makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the

android kotlin rx-java rx-android rx-kotlin 2017-09-14

---

0열

1답변

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

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

android firebase-database reactive-programming rx-java2 rx-kotlin 2017-12-27

---

0열

1답변

일반 관찰 가능에서 PublishRelay를 구독하는 방법?

코 틀린 번호 : fun <T> Observable<T>.circuitBreaker(): Observable<T> { val relay = PublishRelay.create<T>() this.subscribe(relay) return relay.toFlowable(BackpressureStrategy.LATEST).toObser

generics rx-swift rx-cocoa rx-kotlin 2017-11-08

---

0열

1답변

RxKotlin은 - 동적 관찰자 배열

는 내가 단일 작업에 관찰자의 동적 목록을 가지고하는 방법을 그림을 시도하고 개조 2 과 함께 RxKotlin을 사용하고 있습니다. 전체 작업이/ 을 실패 할 때까지, 나는 (캐시/메모리에 저장) 데이터 조작을하고 모든 통지해야하는 작업이 완료되면 첫 번째 관찰자가 작업을 트리거해야하고, 모든 추가 관찰자 기다려야합니다 관찰자들. 여기 내가 무슨 짓을했는지

android kotlin rx-java rx-android rx-kotlin 2017-11-09

---

1열

1답변

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

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

rx-java rx-java2 reactivex rx-kotlin rx-kotlin2 2017-11-19

---

0열

1답변

스프링 5 및 코 틀린 1.1 코 루틴 : rx.Scheduler 유형이 없습니다.

스프링 컨텍스트 5.0.0.RELEASE와 함께 Kotlin 1.1.4-3을 사용하고 있습니다. org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'coroutineAnnotationBeanPostProcessor' defined in

java spring kotlin rx-kotlin kotlinx.coroutines 2017-10-03

---

0열

1답변

삽입 생성자 및 컴패니언 오브젝트

저는 Kotlin을 처음 접했고 값을 주입하려고합니다 (이 예제에서는 Int이지만 실제 코드에서는 Provider 클래스 임) 나는 무엇을하고 있습니까? 여기서 뭐라구? 그리고 x가 왜 미해결 된 참조입니까? class Test @Inject constructor(private val x: Int) { companion object { var

java junit kotlin guice rx-kotlin 2017-05-12

---

0열

1답변

subscribeOn()을 추가하면 관찰 가능 유형의 반환 유형이 변경됩니다.

이해하기 힘든 이상한 문제가 발생했습니다. 나는 callable에서 관찰 할 수있는 것을 생성하는 코드를 작성했다. 그것은 잘 컴파일하지만, 그것에 대해 스케줄러를 지정하자마자 리턴 타입을 변경하고 컴파일하지 않습니다. 여기 는 (컴파일)을 subscribeOn없이 코드 : /** * Gets all the room bookings for the spec

android kotlin rx-kotlin 2017-10-19

---

1열

1답변

필수 입력 : <Object> : <Object>?

class TaskRepo(taskData: TaskData) { companion object { private val repoByTask: LRUMap<String, OrderFormRepo> = LRUMap(2, 10); fun getInstance(taskData: TaskData): OrderFormRepo { i

kotlin kotlin-android-extensions kotlin-extension rx-kotlin kotlin-interop 2017-12-09

---

-3열

1답변

rxkotlin의 groupby에서지도를 가져올 수 없습니다.

rxkotlin groupby is not working을 도와주세요. rxjava에서 작동하지만 kotlin에서는 작동하지 않습니다. 매우

kotlin rx-java rx-kotlin 2017-12-10

---