전체 피드 목록

Overview지난 글 Rxjava를 이용한 안드로이드 개발에서는 RxJava의 Android 연결 방법과 기본적인 사용법을 다뤘습니다. 이번 글에서는 RxJava의 강력하고 다양한 함수들을 살펴보고자 합니다. Android에서 복잡하게 구현되는 내용들을 단 몇 개의 함수로 처리할 수 있는 RxJava를 꼭 사용해보길 권합니다.1. just2. fromArray/fromlterable3. range/rangLong4. interval5. timer6. map7. flatMap8. concatMap9. toList10. toMap11. toMultiMap12. filter13. distinct14. take15. skip16. throttleFirst17. throttleLast18. throttleWithTimeout참고: 공통적으로 사용하는 구독(수신) 클래스는 아래와 같습니다.static class CustomSubscriber<T> extends DisposableSubscriber<T> { @Override public void onNext(T t) { System.out.println(Thread.currentThread().getName() + " onNext( " + t + " )"); } @Override public void onError(Throwable t) { System.out.println(Thread.currentThread().getName() + " onError( " + t + ")"); } @Override public void onComplete() { System.out.println(Thread.currentThread().getName() + " onComplete()"); } } 1. just파라미터를 통해 받은 데이터로 Flowable을 생성하는 연산자입니다. 최대 10까지 전달할 수 있고, 모든 데이터가 수신되면 onComplete() 수신됩니다. 기본적인 Flowable 생성자 함수로 볼 수 있으며 단순 작업에서 많이 사용합니다.public static void just() { //파라미터 값을 순차적으로 송신하는 Flowable 생성 Flowable<String> flowable = Flowable.just("A", "B", "C", "D", "E", "F"); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( A ) main onNext( B ) main onNext( C ) main onNext( D ) main onNext( E ) main onNext( F ) main onComplete() 2. fromArray/fromIterablefromArray, fromIterable 함수는 파리미터로 배열 또는 Iterable(리스트 등)에 담긴 데이터를 순서대로 Flowable을 생성하는 연산자입니다. 모든 데이터를 순차적으로 송신 후 완료됩니다. 반복적인 데이터 변환 작업 같은 경우 for 문 대신 대체할 수 있습니다. 결과를 보면 main Thread 에서 작업 결과가 나오지만, flatMap 을 사용한다면 별도의 Thread로 main Thread의 부하를 막을 수 있습니다.1. fromArray public static void fromArray() { //fromArray 배열로 파라미터를 전달 받는다. Flowable<String> flowable = Flowable.fromArray("A", "B", "C", "D", "E"); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( A ) main onNext( B ) main onNext( C ) main onNext( D ) main onNext( E ) main onComplete() 2. fromIterable public static void fromIterable() { List<String> list = Arrays.asList("A", "B", "C", "D", "E"); //fromIterable 리스트로 파라미터를 전달받는다. Flowable<String> flowable = Flowable.fromIterable(list); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( A ) main onNext( B ) main onNext( C ) main onNext( D ) main onNext( E ) main onComplete() 파라미터와 함수는 다르지만 동일하게 처리된다. 3. range/rangLongrange 함수는 지정한 숫자부터 지정한 개수만큼 증가하는 Integer 값 데이터를 송신하는 Flowable를 생성합니다. rangLong 함수는 range와 동일하며 데이터 타입은 Long을 사용합니다. 두 함수 데이터 송신을 마치면 onComplete를 송신합니다.1. range public static void range() { //range(int start, int count) //start : 시작 값 //end : 발생하는 횟수 Flowable<Integer> flowable = Flowable.range(10, 5); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( 10 ) main onNext( 11 ) main onNext( 12 ) main onNext( 13 ) main onNext( 14 ) main onComplete() 2. rangLong public static void rangeLong() { //range(int start, int count) //start : 시작 값 //end : 발생하는 횟수 Flowable<Long> flowable = Flowable.rangeLong(10, 5); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( 10 ) main onNext( 11 ) main onNext( 12 ) main onNext( 13 ) main onNext( 14 ) main onComplete() 4. interval지정한 간격마다 0부터 시작해 Long 타입 숫자의 데이터를 송신하는 Flowable을 생성합니다. 데이터는 0, 1, 2, 4 순차적으로 증가된 데이터를 송신합니다. Android 에서는 반복적인 작업인 TimerTask를 대신해서 interval로 간단하게 처리할 수 있습니다. UI 변경이 필요한 부분에서는 interval scheduler를 AndroidSchedulers.mainThread() 를 변경해 적용할 수 있습니다.public static void interval() { //(long time, TimeUnit unit, Scheduler scheduler) //time : 발생 간격 시간 //unit : 간격 시간 단위 //scheduler : 발생 scheduler를 변경하여 사용할 수 있습니다. // ex)AndroidSchedulers.mainThread() // - 1 - 2 - 3 - 4 - 5 - 6 - 7 - 8 - 9 // 1초 간격으로 데이터 요청을 송신하다. Flowable<Long> flowable = Flowable .interval(1000L, TimeUnit.MILLISECONDS).take(10); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 1 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onNext( 5 ) RxComputationThreadPool-1 onNext( 6 ) RxComputationThreadPool-1 onNext( 7 ) RxComputationThreadPool-1 onNext( 8 ) RxComputationThreadPool-1 onNext( 9 ) 5. timertimer 함수는 호출된 시간부터 일정한 시간 동안 대기하고 Long 타입 0을 송신 및 종료하는 flowable을 생성합니다. interval이 조건까지 반복적으로 송신한다면, timer는 한번만 송신하고 종료됩니다.public static void timer() { SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy.MM.dd hh:mm ss"); System.out.println("현재시간 : " + simpleDateFormat.format(System.currentTimeMillis())); //(long time, TimeUnit unit, Scheduler scheduler) //time : 발생 간격 시간 //unit : 간격 시간 단위 //scheduler : 발생 scheduler를 변경하여 사용할 수 있습니다. // ex)AndroidSchedulers.mainThread() Flowable<Long> flowable = Flowable.timer(1000L, TimeUnit.MILLISECONDS); //구독을 시작한다. flowable.subscribe(value -> { System.out.println(" timer : " + simpleDateFormat.format(System.currentTimeMillis())); }, throwable -> { System.out.println(throwable); }, () -> { System.out.println(" complete"); }); } 결과 현재시간 : 2019.04.29 09:09 56 timer : 2019.04.29 09:09 57 complete 6. mapFlowable 에서 송신하는 데이터를 변환하고, 변환된 데이터를 송신하는 연산자입니다. 하나의 데이터만 송신할 수 있으며, 반드시 데이터를 송신해야 합니다. 혹여 송신되는 데이터가 null 을 포함하면 map 대신 아래의 flatMap 을사용하는 것이 좋습니다.public static void map() { Flowable<String> flowable = Flowable.just("A", "B", "C", "D", "E") //map(Function mapper) //mapper : 받은 데이터를 가공하는 함수형 인터페이스 //알파벳 값을 소문자로 변경하여 return 한다 .map(value -> value.toLowerCase()); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( a ) main onNext( b ) main onNext( c ) main onNext( d ) main onNext( e ) main onComplete() 7. flatMapflatMap은 map과 동일한 함수이지만, map과는 달리 여러 데이터가 담긴 Flowable을 반환할 수 있습니다. 또한 빈 Flowable를 리턴해 특정 데이터를 건너뛰거나 에러 Flowable를 송신할 수 있습니다.파라미터 mapper에서 새로운 Flowable의 데이터 전달이 아닌 다른 타임라인 Flowable로 작업하면 들어온 데이터 순서대로 출력을 지원하지 않습니다. 타임라인 Flowable(timer, delay, interval 등)에서는 가급적 사용을 피하거나, 순서에 지장이 없을 때 사용하는 것이 좋습니다.public static void flatMap() { Flowable<String> flowable = Flowable.range(10, 2) //flatMap(Function mapper, BiFunction combiner) //mapper : 받은 데이터로 새로운 Flowable를 생성하는 함수형 인터페이스 //combiner : mapper가 새로 생성한 Flowable 과 원본 데이터를 조합해 새로운 송신 데이트를 생성하는 함수형 인터페이스 //첫 번째 데이터를 받으면 새로운 Flowable를 생성한다. //take(3) : 3개까지만 발생한다. .flatMap(value -> Flowable.interval(100L, TimeUnit.MILLISECONDS).take(3), (value, newData) -> "value " + value + " newData " + newData); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( value 10 newData 0 ) RxComputationThreadPool-2 onNext( value 11 newData 0 ) RxComputationThreadPool-1 onNext( value 10 newData 1 ) RxComputationThreadPool-2 onNext( value 11 newData 1 ) RxComputationThreadPool-1 onNext( value 10 newData 2 ) RxComputationThreadPool-2 onNext( value 11 newData 2 ) RxComputationThreadPool-2 onComplete() 결과를 보면 각기 생성된 Flowable이 비동기식으로 송신 되기때문에 서로 다른 스레드에서 실행돼 데이터를 받는 순서대로 송신하지 않는다는 점을 주목하자 8. concatMap받은 데이터를 Flowable로 변환하고 변환된 Flowable을 하나씩 순서대로 실행해서 수신자에서 송신합니다. 다시 말해 여러 데이터를 계속 받더라도 첫 번째 데이터로 생성한 Flowable 의 처리가 끝나야 다음 데이터로 생성한 Flowable을 실행하는 것입니다.생성된 Flowable의 스레드에서 실행되더라도 데이터를 받은 순서대로 처리하는 것을 보장하지만, 처리 성능에 영향을 줄 수 있습니다.public static void concatMap() { Flowable<String> flowable = Flowable.range(10, 5) //map(Function mapper) //mapper : 받은 데이터를 가공하는 함수형 인터페이스 .concatMap(value -> Flowable.interval(100L, TimeUnit.MILLISECONDS).take(2) .map(data -> ("value : " + value + " data : " + data))); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( value : 10 data : 0 ) RxComputationThreadPool-1 onNext( value : 10 data : 1 ) RxComputationThreadPool-2 onNext( value : 11 data : 0 ) RxComputationThreadPool-2 onNext( value : 11 data : 1 ) RxComputationThreadPool-3 onNext( value : 12 data : 0 ) RxComputationThreadPool-3 onNext( value : 12 data : 1 ) RxComputationThreadPool-4 onNext( value : 13 data : 0 ) RxComputationThreadPool-4 onNext( value : 13 data : 1 ) RxComputationThreadPool-5 onNext( value : 14 data : 0 ) RxComputationThreadPool-5 onNext( value : 14 data : 1 ) RxComputationThreadPool-5 onComplete() 결과를 보면 생성된 Flowable 스레드와 데이터 순서대로 출력이 보장된다 것을 알 수 있다. 9. toListtoList는 송신할 데이터를 모두 리스트에 담아 전달합니다. 한꺼번에 데이터를 List로 가공해서 받기에 좋습니다. 하지만 많은 양의 데이터를 처리할 경우 버퍼가 생길 수 있고, 쌓은 데이터 때문에 메모리가 부족해질 수도 있습니다. 또한 수신되는 데이터는 하나이므로 Flowable이 아닌 Single 반환값을 사용합니다.public static void toList() { Single<List<String>> single = Flowable.just("A", "B", "C", "D", "E", "F") .toList(); // 구독을 시작한다. single.subscribe(new SingleObserver<List<String>>() { @Override public void onSubscribe(Disposable d) { System.out.println(Thread.currentThread().getName() + " onNext()"); } @Override public void onSuccess(List<String> strings) { //최종 완료된 리스트를 순서대로 출력한다. for (String text : strings) { System.out.println(Thread.currentThread().getName() + " onSuccess( " + text + " )"); } } @Override public void onError(Throwable e) { System.out.println(Thread.currentThread().getName() + " onError() " + e); } }); } 결과 main onNext() main onSuccess( A ) main onSuccess( B ) main onSuccess( C ) main onSuccess( D ) main onSuccess( E ) main onSuccess( F ) 10. toMaptoMap은 송신할 데이터를 모두 키와 값의 쌍으로 Map에 담아 전달합니다. 나머지는 toList의 특징과 같습니다. 송신되는 데이터 타입은 Map에 담아서 송신하는데 동일한 key에서 value는 마지막 데이터가 덮어 씁니다. 요청되는 값보다 결과 값이 적을 수도 있습니다. List 값을 손쉽게 key, value로 분리할 수 있는 함수이기도 합니다.public static void toMap() { Single<Map<Long, String>> single = Flowable.just("1A", "2B", "3C", "1D", "2E") //toMap(Fuction keySelector, Function valueSelector, Callable mapSupplier) //keySelector : 받은 데이터로 Map에서 사용할 키를 생성하는 함수형 인터페이스 //valueSelector : 받은 데이터로 Map 넣을 값을 생성하는 함수형 인터페이스 .toMap(value -> Long.valueOf(value.substring(0, 1)), data -> data.substring(1)); //구독을 시작한다. single.subscribe(new SingleObserver<Map<Long, String>>() { @Override public void onSubscribe(Disposable d) { System.out.println(Thread.currentThread().getName() + " onNext()"); } @Override public void onSuccess(Map<Long, String> longStringMap) { //최종 완료된 map을 순서대로 출력한다. for (long id : longStringMap.keySet()) { System.out.println(Thread.currentThread().getName() + " onSuccess( id : " + id + ", value " + longStringMap.get(id) + " )"); } } @Override public void onError(Throwable e) { System.out.println(Thread.currentThread().getName() + " onError() " + e); } }); } 결과 main onNext() main onSuccess( id : 1, value D ) main onSuccess( id : 2, value E ) main onSuccess( id : 3, value C ) 11. toMultiMap키와 컬렉션 값으로 이루어진 Map을 데이터로 변환하여 송신하는 함수입니다. 나머지 특징은 toList, toMap과 같습니다. toMap에서 중복되는 value를 관리하는 건 없었지만, value를 collection으로 관리하여 전달되는 데이터를 모두 수신할 수 있습니다.public static void toMultiMap() { Single<Map<String, Collection<Long>>> single = Flowable.interval(100L, TimeUnit.MILLISECONDS) .take(5) //toMultimap(Function keySelector, Function valueSelector) .toMultimap(value -> { //value가 홀수인지 짝수 인지 판단해서 key값을 리턴한다. if (value % 2 == 0) { return "짝수"; } else { return "홀수"; } }); //구독을 시작한다. single.subscribe(new SingleObserver<Map<String, Collection<Long>>>() { @Override public void onSubscribe(Disposable d) { System.out.println(Thread.currentThread().getName() + " onNext( " + d + " )"); } @Override public void onSuccess(Map<String, Collection<Long>> stringCollectionMap) { for (String key : stringCollectionMap.keySet()) { StringBuffer stringBuffer = new StringBuffer(); for (long value : stringCollectionMap.get(key)) { stringBuffer.append(" " + value); } System.out.println(Thread.currentThread().getName() + " onSuccess( id : " + key + ", value " + stringBuffer.toString() + ")"); } } @Override public void onError(Throwable e) { System.out.println(Thread.currentThread().getName() + " onError() " + e); } }); } 결과 main onNext() RxComputationThreadPool-1 onSuccess( id : 짝수, value 0 2 4 ) RxComputationThreadPool-1 onSuccess( id : 홀수, value 1 3 ) 12. filterfilter는 받은 데이터가 조건에 맞는지 판단해 결과가 true인 값만 송신합니다. 위의 just, fromArray, interval이 반복적인 케이스였다면, filter는 if문처럼 조건문의 역할을 할 수 있습니다. 반복문 함수와 조건문 함수를 같이 사용해 몇 줄 안에 for, if와 똑같이 구현할 수 있죠.public static void filter() { Flowable<Long> flowable = Flowable.interval(300L, TimeUnit.MILLISECONDS) //짝수만 통과한다. 3개만큼 .filter(value -> value % 2 == 0).take(3); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 13. distinct이미 처리된 데이터를 다시 볼 필요가 없을 때 사용하는 함수입니다. 송신하려는 데이터가 이미 송신된 데이터와 같다면 해당 데이터는 무시합니다. 이 함수는 내부에서 HashSet으로 데이터가 같은지 확인합니다.public static void distinct() { Flowable<String> flowable = Flowable.just("A", "a", "B", "b", "A", "a", "B", "b") //distinct(Function keySelector) //keySelector : 받은 데이터와 비교할 데이터를 확인하는 함수 //모두 소문자로 변환하여 알파벳 기준으로 데이터를 판단한다. .distinct(value -> value.toLowerCase()); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 main onNext( A ) main onNext( B ) main onComplete() 14. take1.taketake 함수로 지정된 횟수만큼 받은 데이터를 송신합니다. 지정된 횟수에 도달하면 완료를 송신해 처리 종료합니다.2.takeUntil지정된 조건까지 데이터를 송신하는 연산자입니다. 조건이 되면 완료를 송신해 종료합니다.3.takeWhile지정된 조건이 해당할 때만 데이터를 송신하는 연산자입니다.4.takeLast데이터의 끝에서부터 지정한 조건까지 데이터를 송신하는 연산자입니다.take 함수는 한 화면에 출력되거나 칠요한 데이터만큼 리스트에서 값을 하나씩 수신할 때 사용합니다. 예를 들어 화면에 데이터가 6개가 필요하면 take를 이용해 원하는 만큼의 데이터를 가져올 수 있습니다.Flowable.take(6) 또한 이후에 나올 skip 함수를 같이 사용하면 두 번째 화면에서 필요한 데이터를 6개 가져올 수 있습니다.Flowable.skip(6).take(12) 1. take public static void take() { // 100 밀리세컨드만큼 반복하며 총 5개를 출력후 종료한다. Flowable<Long> flowable = Flowable.interval(100L, TimeUnit.MILLISECONDS) .take(5); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 1 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 2. takeUntil public static void takeUntil() { // 100 밀리세컨드만큼 반복하며 값이 5가 될때까지 송신한다. Flowable<Long> flowable = Flowable.interval(100L, TimeUnit.MILLISECONDS) .takeUntil(value -> value == 5); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 1 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onNext( 5 ) RxComputationThreadPool-1 onComplete() 3. takeWhile public static void takeWhile() { // 100 밀리세컨드만큼 반복하며 값이 5가 아닐경우까지 송신한다. Flowable<Long> flowable = Flowable.interval(100L, TimeUnit.MILLISECONDS) .takeWhile(value -> value != 5); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 1 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 4. takeLast public static void takeLast() { //100밀리 세컨트만큼 반복하며 5개의 출력중 뒤에 2개만 송신한다. Flowable<Long> flowable = Flowable.interval(100L, TimeUnit.MILLISECONDS) .take(5) .takeLast(2); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 15. skip1.skip함수로 지정된 횟수만큼 받은 데이터 송신을 제외합니다. 지정된 횟수가 초과되면 나머지 데이터를 송신합니다.2.skipUntil지정된 조건까지 데이터 송신을 제외하는 연산자입니다. 조건이 되면 나머지 데이터를 송신합니다.3.skipWhile지정된 조건이 해당될 때만 데이터 송신을 제외하는 함수입니다.4.skipLast데이터의 끝에서부터 지정한 조건까지 데이터 송신을 제외하는 함수입니다.take와 반대의 기능을 갖고 있습니다. 보통 페이저나 리스트에서 paging을 처리할 때는 take와 skip을 혼용합니다.1. skip public static void skip() { //100 밀리세컨드만큼 반복하며 5번 발행하고, 처음 2개를 제외합니다. Flowable<Long> flowable = Flowable.interval(100L, TimeUnit.MILLISECONDS) .take(5) .skip(2); //구독을 시잔한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 2. skipUntil public static void skipUntil() { //300밀리 세컨드만큼 반복하며 5개를 발행하고, 1000 밀리세컨드 제외 후 송신합니다. Flowable<Long> flowable = Flowable.interval(300L, TimeUnit.MILLISECONDS) .skipUntil(Flowable.timer(1000L, TimeUnit.MILLISECONDS)) .take(5); //구독을 시잔한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-2 onNext( 3 ) RxComputationThreadPool-2 onNext( 4 ) RxComputationThreadPool-2 onNext( 5 ) RxComputationThreadPool-2 onNext( 6 ) RxComputationThreadPool-2 onNext( 7 ) RxComputationThreadPool-2 onComplete() 3. skipWhile public static void skipWhile() { //300밀리세컨드만큼 반복하며 5개를 발행하고, 데이터 3이 올때까지 데이터를 제외힙니다. Flowable<Long> flowable = Flowable.interval(300L, TimeUnit.MILLISECONDS) .skipWhile(value -> value != 3) .take(5); //구독을 시잔한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 3 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onNext( 5 ) RxComputationThreadPool-1 onNext( 6 ) RxComputationThreadPool-1 onNext( 7 ) RxComputationThreadPool-1 onComplete() 4. skipLast public static void skipLast() { //1000 밀리세컨드만큼 반복하며 5개를 발행하고 마지막 2개는 제외합니다 Flowable<Long> flowable = Flowable.interval(1000L, TimeUnit.MILLISECONDS) .take(5) .skipLast(2); //구독을 시작한다. flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 1 ) RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onComplete() 16. throttleFirst데이터를 송신하고 지정된 시간 동안 들어오는 요청을 무시합니다. 이 함수는 View의 Event 처리에서 많이 사용됩니다. 중복되는 처리를 막기 위해 최초 실행 후 일정 시간 동안 View의 클릭 이벤트나 API 이벤트를 막을 수 있기 때문에 비동기 처리와 화면에 직접적인 피드백이 발생했을 때 throttleFirst를 자주 사용하고 있습니다. //데이터 요청이 30 밀리초마다 5번 발생합니다. //데이터 요청 발생시 100 밀리세컨트 동안 들어오는 데이터 요청을 무시합니다. // — 0 — 1 — 2 — 3 — 4 interval 30 밀리초 마다 // — — -*- — throttleFirst 100 밀리초 무시 Flowable<Long> flowable = Flowable.interval(30L, TimeUnit.MILLISECONDS) .take(5).throttleFirst(100L, TimeUnit.MILLISECONDS); flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 0 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 17. throttleLastthrottleLast 함수는 데이터를 송신하고 지정된 시간 동안 들어오는 마지막 요청을 송신합니다. 이 함수도 throttleFirst처럼 반복적인 선택 이벤트 처리에 유용하게 사용할 수 있습니다. 간단하게 장바구니 카운트 변경을 요청할 때 마지막 변경 이벤트 데이터만 처리하면 되므로 값이 선택되고 일정 시간이 지났을 때 API를 요청해 리소스 낭비를 줄일 수 있습니다.public static void throttleLast() { //데이터 요청이 1 초 마다 6번 발생합니다. //데이터 요청 발생시 2 초 동안 들어오는 마지막 요청을 송신하다. // - 0 - 1 - 2 - 3 - 4 interval 1 초 마다 // - - -* - throttleLast 2 초의 마지막 값 송신 Flowable<Long> flowable = Flowable.interval(1, TimeUnit.SECONDS) .take(5) .throttleLast(2, TimeUnit.SECONDS); flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( 2 ) RxComputationThreadPool-1 onNext( 4 ) RxComputationThreadPool-1 onComplete() 18. throttleWithTimeoutthrottleWithTimeout 함수는 데이터를 송신하고 지정된 시간 동안 다음 데이터를 받지 못하면 현재 데이터를 송신합니다. 완료 시엔 마지막 데이터를 송신하고 종료됩니다.public static void throttleWithTimeout() { Flowable<String> flowable = Flowable.<String>create(emitter -> { emitter.onNext("A"); Thread.sleep(1000L); // 1000 밀리세컨드 슬립 // 500 밀리세컨드 동안 데이터 다음 데이터 요청이 없으므로 A 송신 emitter.onNext("B"); Thread.sleep(300L); // 300 밀리세컨드 슬립 emitter.onNext("C"); Thread.sleep(300L); // 300 밀리세컨드 슬립 emitter.onNext("D"); Thread.sleep(1000L); // 1000 밀리세컨드 슬립 // 500 밀리세컨드 동안 데이터 다음 데이터 요청이 없으므로 D 송신 emitter.onNext("E"); Thread.sleep(100L); // 100 밀리세컨드 슬립 emitter.onComplete(); //완료 요청 시 마지막 데이터 송신 후 종료 }, BackpressureStrategy.BUFFER) .throttleWithTimeout(500L, TimeUnit.MILLISECONDS); flowable.subscribe(new CustomSubscriber<>()); } 결과 RxComputationThreadPool-1 onNext( A ) RxComputationThreadPool-1 onNext( D ) main onNext( E ) main onComplete() ConclusionRxJava에서 많이 사용되고, 또 알고 있으면 좋은 함수들을 살펴봤습니다. 브랜디에서도 이 함수들을 응용해 그동안 다양한 기능을 구현했고, 복잡한 함수도 사용하고 있습니다. 지금까지는 Flowable로 송신과 수신이 1 : 1 로 진행되었지만, 다양한 수신자를 사용해 하나의 Flowable로도 다른 화면에서 여러 수신자를 등록하여 반복적인 작업을 할 수 있습니다. 덕분에 같은 작업을 코드 중복 없이 간단하게 구현할 수 있죠.다음 글에서는 2개 이상의 Flowable을 결합해 사용하는 방법과 Android View에서 RxJava를 응용하는 방법, 구독을 관리하는 방법 등 Android에서 유용하게 쓰는 방법들을 알아보겠습니다.글고재성 팀장 | R&D 개발MA팀[email protected]브랜디, 오직 예쁜 옷만

연말이 되어가고 있어요. 그러니 매출과 비용정리를 해야해요. 세금을 내야하니까요. 어김없이 이 맘때쯤 되면 지난 한 해동안 뭘 얼마나 벌고 살았나...하면서 회고를 하게 되죠. 그 끝은 늘 우응어어어어엉 내인생은 망했어어어.... 통곡! 하나님! 애솔! 댐잇.... 뭐 이런 식인데 올해도 마찬가지였어요.젠장 갓대밋!하지만, 올해의 조금 다른 점이 있다면 나름 유의미한 목표수치를 넘겼다는 거예요. 연매출이 드디어..(4년만에) 1억을 넘겼어요. 작년이 5천이 조금 넘은 수치였으니 수치상으론 두 배로 뛰었네요. 기분이 좋아요. 그렇다고 남는 돈이 그만큼 남았냐.. 음음 그렇지 않죠. 돈은 늘 은행에 있는 거지, 나에게 있는 것이 아니예요.그냥 느낌적으로 유의미한 것 뿐이죠.사실 개인사업을 하면서 1억매출은 큰 게 아니예요. 오히려 4년만에 1억이면... 그동안 뭐했니?... 라는 소릴 들어도 시원찮을 액수랄까요..-.- 그런걸 생각하면 좀 시무룩하기도 하지만, 어차피 인생 다 마이페이스가 있는 것 아니겠어요? 내년에 또 두 배를 하면 되지! 라고 생각하고 그냥 덮으려고 해요. (정신승리)오늘의 글은 자랑이 아니예요. 한 해 동안 잘 먹고 살 수 있게 많은 도움을 주신 분들과 한 해를 대강 정리하며 좀 차분하게 생각해보려고 해요. 뭘 어떻게 해서 묵고 살았는지 말이죠. 그리고 내년엔 어떻게 묵고 살지에 대해서 말입니다.올 한해 디자인 작업을 도와준 녀석은 단명하신 제 2016년 그램과 새로 얻은 2018그램입니다. 맥이 있긴 하지만 녀석은 올해 좀 쉬었어요. 올데이그램이라곤 하지만 사실 올데이는 아닌 것 같고 그냥저냥 오래 잘 살아있다...는 느낌정도인 것 같아요. 그램의 최대장점은 그냥 가벼움이니까 가벼움으로 모든 걸 커버치겠어요. 타닥타닥 하는 가벼운 키감이 처음엔 시끄러워서 거슬렸는데 어차피 전 헤드셋을 끼고 일하니 제 타자소리가 들리진 않아요. 독서실같은 곳에선 일하기가 좀 그렇긴 하더라구요. 응 고생했어. 수고했으니까 청소해줄께또..음. 올 한해의 1등 BGM은 역시 나루토짱이었습니다. 나루토질풍전 ost는 차크라를 증폭시켜주고, 불의 의지에 대해 다시 생각하게 해주죠. 초심을 잃지 않게 만들어주는 훌륭한 배경음악이라고 할 수 있겠습니다.오레노 닌도다!또.. 올 해의 코스튬은 유니클로 후드티에게 영광을 돌리고 싶네요. 유니클로 보들보들 후드티는 가성비측면에서 가히 오진다고 할 수 있겠습니다. 특히 보들보들한 면소재때문에 엎드려 잘 때 볼에 닿는 느낌이 꽤나 좋다는 잔점(단점+장점)이 있습니다. 덕분에 잘 잤습니다. 마약같은 후드...자 그럼 헛소리 그만하고 1월부터 한 번 생각해볼께요.1월작년에 브런치에서 뿌앙! 터진 이후로 여기저기서 글써달란 의뢰가 몇 번 들어왔는데, 그 중 꽤 괜찮은 페이로 웹매거진 기고를 요청한 곳이 있었어요. S사였죠. 편당 70이었나? 그랬던 것 같아요. 6개정도로 호다닥 써서 드리게 되었죠. 페메로 연락이 왔고, 이래저래 커뮤니케이션의 미스가 있었어서 초반엔 좀 아리까리했었어요. 이게 맞나....? 싶었기도 하구요. 사실 다른 콘텐츠도 계속 만듭시다!~ 라고 했는데 상황도 상황이고, 뭔가 결이 좀 다른 것 같아서 리젝하게 되었답니다.하지만, 글로도 수익이 날 수 있다는 걸 알게 된 프로젝트여서 유의미했던 것 같아요. 그리고 책읽찌라 대표님이 서평써달래서 '생산성' 이란 책의 서평을 쓰고 소정의 용돈을 받았지요. (넙죽)작년12월부터 2월까진 부산에서 플젝을 했었거든요. 그때 저의 부산라이프를 행복하게 만들어주신 양대표님이 또 잊지않고 무슨 추가비용을 주셔서(뭐였는진 잘 기억이 안남..) 그것도 용돈이 조금 되었어요. 1월매출 = 250만원2월2월엔 서울로 호다닥 올라왔답니다. 부산생활이 끝난터라 적응도 안되고 막 정신도 없었지만...사실 올라오자마자 바로 미팅을 하고 일을 시작했어요. 뭐였냐면 S사의 웹소설 플랫폼을 만드는 일이었어욤. 사실 웹디자인은 그렇게 깊이있게 해본 적이 없어서 처음에 얼마나 후덜덜 했는지 몰라요. 사실 대표님께서 솔직하게 말씀드렸었거든요. 하아..이걸 내가 잘 할 수 있을 지 모르겄다...근데 그냥 하라고 하시더라구요. 개쿨했다. 3개월동안 세상 시원시원한 프로젝트를 했어요. 대표님이 이거 하자! 개발자님이 안된다! 나도 안된다! 대표님은 그래!하지말자! 이런 식의 우주적 커뮤니케이션을 경험했답니다. 이 세상 회의가 아니다.....아직 돈은 안받았어요. 돈은 3월, 4월에 걸쳐서 나눠 받기로 했지요.2월엔 1월에 하던 기고 잔액을 받았고..한 250만원? 정도 됬어요. 그리고 IR자료 하나 만들어드리고 한 200정도 받았던 것 같고, 브런치북 프로젝트 상금이 들어왔다는!! 세금떼고 96만원 정도가 쏘옥..(꽁돈기분).그리고 부산프로젝트 잔금도 이 때 들어왔어요. 200만원 정도. 그리고 서울에서 쪼꼬미하게 강연한거 17만원.2월매출 = 738만원3월3월엔 강의건이 크게 있었어요. 3일에 걸쳐서 18시간인가? 하는 극강의 온종일 워크샵이었죠. 포토샵이랑 기타 등등 스타트업에 취업하고 싶은 취준생들 대상으로 디자인실무 강의해주는 거였는데, 오랜만에 학식 돈까스를 먹어서 굉장히 뜻깊었습니다. 충남대까지 왔다갔다하면서 대전의 겨울을 맛보았죠. (다를게 없었음). 이것도 브런치 때문에 막 뜨면서 섭외가 들어온 건이었어요. 그걸로 한 300만원 정도 들어왔었어요.그리고 기획재정부 산하 KDI에서 프로젝트를 하나 맡아서 했었죠. 어떻게 알게 되었냐면..음 저랑 페친님이 제 브런치 팬이었는데..... 그 페친님이 자기 여친님께 절 소개했나봐요. 그 여친님이 KDI담당자분이셨고, 그렇게 저렇게 둘러둘러 연락이 오게 된 케이스랍니당. 전시관 소개서와 기타 등등 몇 가지를 만들고 320만원 정도.. 했던 것 같아요. 이건 능력자 디자이너님인 조경하 디자이너님과 함께했었어요!그리고 이 때 책 인쇄들어가면서 선인세 100만원 받았구, 아까 웹디자인 프로젝트 중도금 받았죠 :) 야호! 그리고 IR자료 만드는거 한 건 더들어와서 400만원 플러스!3월매출 = 1,891만원4월아까 KDI에서 추가로 백드롭월이랑, 현수막 등 제작 몇 개 맡겨서 그거 한 건 처리했어요. 그리고 웹디자인 프로젝트 끝나면서 잔금+추가비용 받았죠! 4월은 웹디자인 마무리 짓고 드러누워 요양하느라 아무것도 못한 달이예요... 4월매출 = 925만원5월얼레?강의 한 건 뛰고..암 것도 안함.. 요양(사실상 강제요양..일 안들어옴..)5월매출 = 42만원6월어떡하지...6월도 암것도 ..안...아니 못함... 일 하나도 안들어와서 내 인생은 종착역을 발견한 여름이었어요. 돈 좀 벌었다고 새로 이사하면서 무인양품에서 250만원 어치를 사서 들여왔는데 아씨..내가 왜 그런 짓을 했을까..를 하루12번 되뇌었죠. 혹시라도 이것을 중고나라에 되판다면 착불로 해야하나 어째야하나 진지하게 고민해보기도 했습니다.6월매출 = 0원7월KDI에서 포스터를 만들어달래서 야호!!! 거렸어요. 사실 공공기관 포스터는 딱히 큰 비용은 아니지만..그래두 지난 2달간 10손가락을 번갈아 빨아먹으며 연명하던터라 마냥 기뻤죠. 그리고 Y사에서 회사 아이덴티티를 위한 워딩(회사소개문구와 슬로건 등)을 짜달라는 의뢰가 왔어요. 싱기방기... https://brunch.co.kr/@roysday/218이것을 참고해주세용!~ 이 일과 더불어 강의 2개 정도를 뛰었어요. 작년부터 잡코리아와 계속 일을 하고 있는데, 올해도 어김없이 불러주셔서 간간히 예상치 못한 용돈을 받고 있지요. 7월매출 = 275만원8월휴우 살았다. 보릿고개 클리어8월엔 신촌에 박스퀘어라는 소상공인 플랫폼이 만들어지면서 거기 입점매장 대상으로 브랜딩을 도와주는 역할을 조금 했어요. 이 때 담당하시던 이사님이 예전에 제가 잡코리아에서 강의할 때 그 때 연을 맺게 된 분이었는데 나오셔서도 찾아주시더라구요 :) 너무 감사함...그리고 패스트캠퍼스에서 강의를 3개월간 쭈우우우욱....진행했던 게 끝나서 비용을 톡 받았고. 강의 4개정도 뛰면서 다시 삼시세끼를 챙겨먹게 되었어요.8월매출 = 360만원9월박스퀘어 브랜딩을 계속 진행했어요! 그리고 두번째책을 웨일북과 계약하면서 선인세를 조금 받았답니다. 9월은 계속 박스퀘어 일을 하면서 후다다다다닥 바빴던 것 같아요. 그리고 이 때 아주 소중한 인연을 맺게 된 분이 생겼죠.9월매출 = 292만원10월9월은 사실상 한 템포 쉬어가는 달이었어요. 사실 이땐 비수기라기보단 한참 프로젝트가 될랑말랑하다가 다 엎어져버린 달이었거든요. 루이까또즈랑 대전시랑 뭐 이것저것 있었는데..프로젝트가 연기되고, 캔슬되고, 비딩떨어지고 뭐... 이것저것 우주만물이 저보고 아무것도 하지 말라고 외치는 듯한 기분이었어요. 잠시 멘붕을 겪을 뻔 했는데.... 10월이 대박쓰. 계속 자료가 안와서 하는건지 마는건지 애매하던 프로젝트가..오픈되었고. IR과 원페이지 회사소개서 제작이... 시작되었죠. 약 20개업체의 소개페이지를 제작하기 시작했어요. 10월은 그거 쳐내느라 정신을 못차렸어요. 그 프로젝트의 계약금을 받았답니다! 참고로 이 클라이언트님과는 두 해째 함께 하고 있는데..정말정말 클리어하고 깔끔하세요. 정말 뒤끝도 자잘한 간섭도 없고 원하는 것만 빨리 정확히 잘 만들어드리면 바로바로 오케이 해주시는... 하아.. 열두번 절받으세요.10월매출 = 1571만원11월이번 달이예요. 이번달은.... 그 20개업체가 다 끝났어요. 그리고 추가 외국 스타트업들의 IR자료...그것 더하기 또 다른 지원사업에 참여하는 스타트업들의 소개서제작..(또 20개업체...) 등등 뭐 엄청나게 우르르르르 제작을 해야해요. 이번달은 네 그냥 딱 내 몸은 클라이언트의 것이다..생각하고 자본주의의 섭리에 저를 내맡기려고 합니다. 이 프로젝트는 1월10일까지 계속되요!!~그리고 패스트캠퍼스 두번째 강의가 오픈되었고....강의가 5개정도 잡혔고... 책도 쓰고 있고...(11월 뭐지?!)....그렇습니다. 11월매출 = 1476만원12월12월은 아마 잔금들이 우르르 들어오겠죠. 12월10일부턴 잠시 여행을 슝 다녀올 계획이지만...지금 상태라면 아이슬란드의 오로라를 보면서도 오브젝트 선 따고 있어야 할지 모르겠다는 생각이 들어요. 여튼 12월엔 잔금이 호로록 들어오면.. 이제 올해의 매출이 땋 끝나고..종소세 신고를 해야하죠. 12월매출 = 2,224만원그래서..이것저것 막 다 합쳐보니 1억 4백만정도가 나왔어요. 증말 간신히...턱걸이로 넘겼네요.지난 1년간 하루는 널널하고 하루는 지옥같은 일상이 반복되었던 것 같아요. 하지만 다행스럽게도 저와 함께 일해준 클라이언트님들과 협력업체 사장님들, 동료디자이너님들이 너무너무 좋으신 분들이어서 또 이렇게 행복하게 1년을 마무리 지을 수 있었습니다. 이빨까는 게 아니라 진심입니다.올해 1월엔 과연 올해 내 목표매출을 찍을 수 있을까...하고 엄청 고민하고 불안해했었어요. 작년에 브런치글이 여기저기 퍼지면서 연락이 많이 온터라 부담도 되었고... 이 성과가 내 것이 아닌 것 같아서 방향을 잡기가 어려웠거든요. 하지만...정말 이 대표님의 말처럼(제가 존경하는 멘토님..) 사업은 생각하고 고민하는게 아니라 행동하는 거라는 말이 맞는 것 같아요. 그냥 하다보니 이렇게 왔고.. 의도하지 않았지만 의도처럼 되어버리기도 하거든요.전 여전히 내년을 걱정하고 있어요. 내년에도 또 새롭고 신기한 것들을 해볼 생각인지라 설레기도 하지만... 여전히 두렵고 떨리죠. 하지만.. 내년에도 여전히 좋은 사람들이 많을 거고, 제 그램도 쌩쌩 잘 돌아갈 것 같아요. 과감하게 두 배 매출을 한 번 고려(?)해보려고 합니다...뭐 어케 되겠지.고려를 하겠다고 했지 할 수 있다고는 안했다.