개발 일기

Debounce 특정 시간을 지난 후에 마지막의 하나의 이벤트만 발생을 합니다. val subject = BehaviorSubject.create() subject.debounce(1, TimeUnit.SECONDS).subscribeBy { println(it) } subject.onNext(1) subject.onNext(2) Thread.sleep(2000) subject.onNext(3) Thread.sleep(5000) // 2 , 3 출력 Distinct Stream에서 중복된 값을 제거를 합니다. Observable.fromArray(1,2,3,4,5,6,1,2,3).distinct().subscribeBy { println(it) } // 1,2,3,4,5,6 마지막에 들어온 값하고 바로이..

Filtering Collection에서 Filter에서는 lambda 함수를 가질수가 있습니다. lambda 함수에서는 return 값을 true / false를 가질수가 있습니다. 가장 기본적인 filtering 함수는 filter() 입니다. filter에서는 각각의 요소에 조건에 맞는 값으로 새로운 Collection을 만듭니다. [예시] val numbers = listOf("one", "two", "three", "four") val longerThan3 = numbers.filter { it.length > 3 } println(longerThan3) val numbersMap = mapOf("key1" to 1, "key2" to 2, "key3" to 3, "key11" to 11) va..