티스토리 뷰
fillter() 함수
public class FillterEx {
public static void main(String[] args) {
Integer[] numbers = {100, 200, 300, 400, 500};
Single<Integer> single;
Observable<Integer> source;
// 1. first : 첫 번째 항목만 리턴 나머지는 모드 걸러낸다.
single = Observable.fromArray(numbers).first(-1);
single.subscribe(data -> System.out.println("first(-1) value = " + data));
System.out.println("======================");
// 2. last : 마지막 항목만 리턴
single = Observable.fromArray(numbers).last(999);
single.subscribe(data -> System.out.println("last(999) value = " + data));
System.out.println("======================");
// 3. take(N) : 처음부터 N개 데이터만 가져옴
source = Observable.fromArray(numbers).take(3);
source.subscribe(data -> System.out.println("take(3) value = " + data));
System.out.println("======================");
// 4. takeLast(N) : 마지막 항목기준으로 N 개의 데이터를 가져 온다
source = Observable.fromArray(numbers).takeLast(3);
source.subscribe(data -> System.out.println("takeLast(3) value = " + data));
System.out.println("======================");
// 5. skip(N) : N 개의 항목을 건너 띄고 그 다음 데이터를 활용
source = Observable.fromArray(numbers).skip(2);
source.subscribe(data -> System.out.println("skip(2) value = " + data));
System.out.println("======================");
// 6. skipLast(N) : 마지막 옴고을 기준으로 N개의 함목을 제외한 다음 데이터를 활용
source = Observable.fromArray(numbers).skipLast(3);
source.subscribe(data -> System.out.println("skipLast(3) value = " + data));
System.out.println("======================");
}
}
'RxJava ' 카테고리의 다른 글
map 함수 (0) | 2019.02.07 |
---|---|
flatMap() 함수 (0) | 2019.01.23 |
RxJava Subjsct class (0) | 2019.01.18 |
Java8 Function, Consumer, Predicate, Supplier (0) | 2019.01.10 |