RxSwift) Time-based Operators ( interval )

interval

일정 주기마다 정수를 방출하는 옵저버블 입니다.

public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType)
    -> Observable<Element> {
    return Timer(
        dueTime: period,
        period: period,
        scheduler: scheduler
    )
}

period: RxTimeInterval 타입은 RxAbstractInteger 입니다. FixedWidthInteger 의 별칭으로 선언되어있습니다. 코드 참조

public typealias RxAbstractInteger = FixedWidthInteger

Apple Developer Documentation

period 은 쉽게 말해서 Int 를 포함한 다른 정수타입을 모두 사용할 수 있습니다.

let oneSecondeIntervalObservable = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)

var subscription1 : Disposable = oneSecondeIntervalObservable.subscribe{ print("1번 구독 : \\($0)") }
DispatchQueue.main.asyncAfter(deadline: .now() + 5) {
    subscription1.dispose()
}

var subscription2 : Disposable = oneSecondeIntervalObservable.subscribe{ print("2번 구독 : \\($0)") }
DispatchQueue.main.asyncAfter(deadline: .now() + 8) {
    subscription2.dispose()
}
       
var subscription3 : Disposable = oneSecondeIntervalObservable.subscribe{ print("3번 구독 : \\($0)") }
DispatchQueue.main.asyncAfter(deadline: .now() + 10) {
    subscription3.dispose()
}

출력

첫번째 구독 : next(0)
두번째 구독 : next(0)
세번째 구독 : next(0)
첫번째 구독 : next(1)
두번째 구독 : next(1)
세번째 구독 : next(1)
첫번째 구독 : next(2)
두번째 구독 : next(2)
세번째 구독 : next(2)
첫번째 구독 : next(3)
두번째 구독 : next(3)
세번째 구독 : next(3)
첫번째 구독 : next(4)
두번째 구독 : next(4)
세번째 구독 : next(4)
두번째 구독 : next(5)
세번째 구독 : next(5)
두번째 구독 : next(6)
세번째 구독 : next(6)
두번째 구독 : next(7)
세번째 구독 : next(7)
세번째 구독 : next(8)
세번째 구독 : next(9)

interval 연산자는 내부에 타이머가 있습니다. 구독자가 옵저버블을 구독할때 타이머가 시작됩니다. 이 타이머는 새로운 구독이 추가 될 때마다 내부적으로 생성됩니다.

출력결과를 보면 “첫번째 구독 : next(5)” 가 없습니다. 시간 단위에선 밀리초 만큼에 오차가 있기에 5번째 이벤트를 발생하지 않고 dispose 되었습니다.