[Rx] 2. 연산자[1]

Observeble 연산자 1. just fun A(){ val item = Observable.just(1,2,3,4,5,6,7,8,9,3) val observer = item.subscribe(::println) } - just는 입력받은 순서대로 데이터를 발행 해준다. - 최대 10개까지 입력을 받을 수 있다. - 입력받은 데이터를 모두 발행하면 dispose를 실행하여 더 이상 구독자는 데이터를 받지 않게된다. 2. Create fun B(){ val item = Observable.create { it.onNext(1000) it.onNext(5000) it.onNext(10000) it.onComplete() } val observer = item.subscribe(::println) } - ..

2020.05.05