XELP
'Developer/RxJava or RxKotlin' 카테고리의 글 목록

Developer/RxJava or RxKotlin

Developer/RxJava or RxKotlin

Observable

- Hot Observable - 마치 라이브 방송을 하듯, 발행 이후 모든 구독자들에게 같은 값을 뿌린다. val src: ConnectableObservable = Observable.interval(1, TimeUnit.SECONDS) .publish() src.connect() src.subscribe { value: Any -> println("First: $value") } Thread.sleep(3000) src.subscribe { value: Any -> println("Second: $value") } Thread.sleep(3000) ConnectqableObservable로 Hot Observable을 생성하여 publish한다. 이후 connect()함수를 작성해야 발행이 시작된다..