RxKotlin- Part 8-2. 필터 연산자 : filter(), take(), skip(), distinct()
filter() filter() 함수는 Observable에서 필요없는 데이터는 제거하고, 원하는 데이터만 filter()를 통해 걸러집니다. fun main() { val arr = arrayOf(1, 2, 3, 4, 5) val ob = Observable.fromArray(*arr) .filter{ it > 3 } ob.subscribe(System.out::println) } 실행결과 : 4 5 take() 첫번째부터 i번째 데이터를 Observer에게 보냅니다. fun main() { val arr = arrayOf(1, 2, 3, 4, 5) val ob = Observable.fromArray(*arr) .take(3) ob.subscribe(System.out::println) } 실행결과 ..
RxKotlin- Part 8. Reactive 연산자
Reactive 연산자 연산자 종류 연산자 함수 생성(Creating) just(), fromXXX(), create(), interval(), range(), timer(), intervalRange(), defer(), repeat() 옵저버블, 싱글 클래스 등으로 데이터의 흐름을 만들어내는 함수입니다. 변환(Transforming) map(), flatMap(), concatMap(), switchMap(), groupBy(), scan(), buffer(), window(), reduce() 어떤 입력을 받아 원하는 출력 결과를 내는 함수입니다. 필터(Filter) filter(), take(), skip(), distinct() 입력 데이터 중 원하는 데이터만 걸러냅니다. 합성(Combining..
