Rx

Question

에있는 서브 스크립터로 객체를 반복하여 반복적으로 Rx에있는 동일한 객체를 가입자에게 보낼 수 있습니까?

val exmp = listOf("А") 
     var observable = exmp.toObservable() 
      observable.subscribeBy(
        onNext = { 
         it + "1" 
         println(it) 
        }, 
        onError = { it.printStackTrace() }, 
        onComplete = { println("Done!") } 
      ) 

내가 "A"반복 방법 onNext을 문자열 값을 전송()와 "A111111"를 얻으려고 : exmaple (코 틀린에)이 코드를 . Rx 라이브러리의 replay() 메소드가 새로운 하위 구독자를 위해 날짜를 다시 보내기 시작하는 것을 알고 있습니다. 동그라미 for 관찰 할 수있는 날짜가 변경되지 않고 그냥 메서드가 여러 번 호출됩니다

Answer 1

observable observable.publish()를 수행하여 관측 가능한 ConnectableObservable을 만들 수 있습니다. 이런 식으로 모든 가입자는 동일한 정보를 얻을 수 있으며 객체는 한 번만 생성됩니다. https://github.com/ReactiveX/RxJava/wiki/Connectable-Observable-Operators