RxSwift - Time-based Operator

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
    .take(6)
    .delaySubscription(.seconds(3), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/*
3초가 지난 후에...
next(0)
next(1)
next(2)
next(3)
next(4)
next(5)
completed
*/
Swift
복사

delay

next 이벤트가 전달되는 시점을 지연

delaySubscription과는 반대로 구독 시점을 지연시키지 않고, next 이벤트의 전달을 지연시킵니다.

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
    .take(6)
    .debug()
    .delay(.seconds(3), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)

// subscribed는 지연되지 않지만, next 이벤트가 나오는건 3초 뒤부터
/*
(bind()) -> subscribed
(bind()) -> Event next(0)
(bind()) -> Event next(1)
(bind()) -> Event next(2)
(bind()) -> Event next(3)
next(0)
(bind()) -> Event next(4)
next(1)
(bind()) -> Event next(5)
(bind()) -> Event completed
(bind()) -> isDisposed
next(2)
next(3)
next(4)
next(5)
completed
*/
Swift
복사

Timer Operator

이벤트가 방출되는 시간 간격을 설정 가능한 연산자입니다.

interval

지정된 주기마다 정수 타입의 값을 방출

지정된 주기마다 정수 타입의 값을 지속적으로 발행합니다. 따라서, 해당 Observable을 중지하기 위해서는 .take 메서드를 사용해서 발행되는 이벤트의 수를 제한하거나, dispose를 직접 호출해야 합니다.

Observable<Int>
    .interval(.nanoseconds(1), scheduler: MainScheduler.instance)
    .take(until: { $0 == 20 }, behavior: .inclusive)
    .subscribe { print($0, terminator: " ") }
    .disposed(by: disposeBag)

/*
next(0) next(1) next(2) next(3) next(4) next(5) next(6) next(7) next(8) next(9) next(10) next(11) next(12) next(13) next(14) next(15) next(16) next(17) next(18) next(19) next(20) completed
*/
Swift
복사

timer

지연 시간과 반복 주기를 지정해서 정수 타입의 값 방출

timer도 interval과 동일하게 Observable을 중지하기 위해서는 .take메서드를 사용해서 발행되는 이벤트 수를 제한하거나, dispose를 직접 호출해야 합니다. interval과는 다르게 dueTime를 추가해서 이벤트 발행이 지연되는 시간을 만들 수 있습니다.

Observable<Int>.timer(.seconds(3), period: .seconds(1), scheduler: MainScheduler.instance)
    .take(until: { $0 == 10 }, behavior: .inclusive)
    .subscribe{ print($0, terminator: " ") }
    .disposed(by: disposeBag)

/*
next(0) next(1) next(2) next(3) next(4) next(5) next(6) next(7) next(8) next(9) next(10) completed
*/
Swift
복사

timeout

지정된 시간 이내에 요소를 방출하지 않으면 에러 이벤트 전달

•

에러 방출

let subject = PublishSubject<Int>()

subject.timeout(.seconds(3), scheduler: MainScheduler.instance)
    .subscribe{ print($0) }
    .disposed(by: disposeBag)

// 아무런 이벤트도 방출되지 않아서 3초 뒤에 에러 이벤트가 전달
/*
error(Sequence timeout.)
*/
Swift
복사

•

정상 작동

let subject = PublishSubject<Int>()

subject.timeout(.seconds(3), other: Observable.just(1), scheduler: MainScheduler.instance)
    .subscribe{ print($0) }
    .disposed(by: disposeBag)

Observable<Int>.timer(.seconds(2), period: .seconds(5), scheduler: MainScheduler.instance)
    .subscribe(onNext: { subject.onNext($0) })
    .disposed(by: disposeBag)

// 이벤트가 방출됐기 때문에 에러 이벤트가 전달되지 않음
/*
next(0)
next(1)
completed
*/
Swift
복사

debounce

타이머를 지정해두고 타이머가 끝난 시점에 가장 최근의 값을 방출

연속적인 이벤트가 발생했을 때, 특정 시간 범위동안 다른 이벤트가 발생되지 않는다면 가장 마지막에 발생한 이벤트만 방출되고 나머지 연속적인 이벤트는 block해주는 역할을 합니다.

debounce는 이벤트가 방출될 때마다 타이머가 초기화됩니다.

textField.rx.text.orEmpty
    .debounce(.seconds(1), scheduler: MainScheduler.asyncInstance)
    .subscribe(onNext: { text in
        print(text)
    })
    .disposed(by: disposeBag)

// 이벤트가 발생한 직후 1초동안 어떠한 다른 이벤트가 발생하지 않는다면 그대로 이벤트가 방출되고, 
// 연속적으로 이벤트가 발생한다면 block 해주는 역할
Swift
복사

throttle

타이머를 지정해두고 이벤트가 처음 방출되면 지정된 시간동안 어떤 이벤트도 방출하지 않음

throttle는 이벤트가 발생하는 최소 간격을 제한할 수 있는 Operator입니다. 어떤 이벤트가 방출되는 시점에서 지정한 시간동안 이벤트들을 block함으로써, 이벤트가 방출되는 간격을 제한할 수 있습니다.

•

latest = true

throttle에는 latest라는 매개변수가 있는데 해당 영역을 true로 설정하게 되면, 지정 시간 뒤에 가장 최근 값을 한 번 더 방출하게 됩니다.

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
    .take(10)
    .throttle(.seconds(2), latest: true, scheduler: MainScheduler.instance)
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

// emit(0) - 1 - emit(2) - 3 - emit(4) - 5 - emit(6) - 7 - emit(8) - 9 - emit(9) - completed
/*
0
2
4
6
8
9
*/
Swift
복사

•

latest = false

latest가 false면 처음 방출된 이벤트만 방출되고 타이머 시간동안 어떤 이벤트도 방출되지 않습니다.

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
    .take(10)
    .throttle(.seconds(2), latest: false, scheduler: MainScheduler.instance)
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

// emit(0) - 1 - emit(2) - 3 - emit(4) - 5 - emit(6) - 7 - emit(8) - 9 - completed
/*
0
2
4
6
8
*/
Swift
복사

debounce와 throttle는 비슷해 보입니다. 차이가 있나요?

•

debounce

debounce는 여러 번 발생하는 이벤트에서, 가장 마지막 이벤트만을 실행되도록 만드는 개념입니다.

즉, 시간 값이 1초일 때 중복으로 99초동안 100번 누르면 1번 반영되는 것이 debounce 입니다. 그렇기 때문에, debounce는 자동완성이나 연관검색어 노출에 사용하는 것이 적합합니다.

텍스트 필드에 텍스트가 여러번 들어오는 동안은 해당 텍스트를 방출하지 않다가 잠깐 멈추는 동안 해당 텍스트를 자동완성하거나 연관검색어를 불러오는 것이죠. 아니라면, 서버에 해당 텍스트를 검색하는 순간순간에도 요청을 하게 될 겁니다.

•

throttle

throttle는 여러 번 발생하는 이벤트를 일정 시간동안 한 번만 실행되도록 만드는 개념입니다.

즉, 시간 값이 1초일 때 0.9초동안 100번 누르면 2번 반영(latest = true)됩니다. 그렇기 때문에, throttle는 버튼 탭이나 스크롤을 내리면서 몇 천개의 데이터를 요청할 때 적합합니다.

버튼을 눌렀을 때, 탭이 중복적으로 눌러진다면 잘못된 요청이 전달될 수도 있습니다. 하지만, 탭이 발생하고나서 몇 초동안 탭을 할 수 없다면 잘못된 값이 전달될 위험이 줄어들게 될 것 입니다.