fillter() 함수 public class FillterEx { public static void main(String[] args) { Integer[] numbers = {100, 200, 300, 400, 500}; Single single; Observable source; // 1. first : 첫 번째 항목만 리턴 나머지는 모드 걸러낸다. single = Observable.fromArray(numbers).first(-1); single.subscribe(data -> System.out.println("first(-1) value = " + data)); System.out.println("======================"); // 2. last : 마지막 항목만 리턴 sin..
public class class03 { public static void main(String[] args) { /*String[] balls = {"1", "2", "3", "4", "5"}; Observable source = Observable.fromArray(balls) .map(getDiamond); source.subscribe(System.out::println);*/ String[] balls = {"RED", "YELLOW", "GREEN", "BLUE"}; Observable source = Observable.fromArray(balls) .map(ballToIndex); source.subscribe(System.out::println); } static Function getD..
flatMap() 함수 :map 함수는 1대1 함수라면 flatMap함수는 일대다 혹은 일대일 Observable 함수이다. public class FlatMap { public static void main(String[] args) { String[] ball = {"1", "2", "3", "4", "5"}; Observable source = Observable.fromArray(ball) .flatMap(getDoubleDiamond); source.subscribe(System.out::println); } static Function getDoubleDiamond = ball -> Observable.just(ball + "", ball + ""); } public class Ex4 { pu..