<div id="readability-page-1" class="page"><div>                        <p data-ke-size="size16">Creating에 속하는 Interval operator에 대해서 알아볼 것이다.&nbsp;</p>

<h3 data-ke-size="size23"><b>1. 정의</b></h3>
<p data-ke-size="size16">주어진 시간 간격을 두고 주기마다, emit되는 옵저버블을 생성한다. Interval 연산자의 경우 completed 되지 않고, 무한한 시퀀스를 생성한다. 즉, 직접 dispose 시키지 않는다면 구독 이후에 계속 반복되는 것이다!</p>
<figure data-origin-width="1280" data-origin-height="390" width="700" height="213" data-ke-mobilestyle="widthOrigin"><span data-url="https://blog.kakaocdn.net/dn/VLlRA/btreCrKcAxL/zD16G512EzJeVYWwJdDZNk/img.png" data-lightbox="lightbox" data-alt="Interval"><img src="https://blog.kakaocdn.net/dn/VLlRA/btreCrKcAxL/zD16G512EzJeVYWwJdDZNk/img.png" data-origin-width="1280" data-origin-height="390" width="700" height="213" data-ke-mobilestyle="widthOrigin"></span><figcaption>Interval</figcaption></figure>
<h3 data-ke-size="size23"><b>2. 구현</b></h3>
<p data-ke-size="size16">Observables의 Timer에서 구현 내용을 살펴볼 수 있다.&nbsp;</p>
<pre id="code_1631193081070" data-ke-language="swift" data-ke-type="codeblock"><code>public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType) -&gt; Observable&lt;Element&gt; {
    return Timer(
        dueTime: period,
        period: period,
        scheduler: scheduler
    )
}</code></pre>
<p data-ke-size="size16">파라미터를 살펴보자.</p>
<ul data-ke-list-type="disc">
<li>period : 주기를 의미한다. 1초로 설정하면 1초마다 옵저버블을 반한하게 되는 것이다</li>
<li>scheduler : 작업을 수행할 스케줄러를 고른다.&nbsp;</li>
</ul>
<h3 data-ke-size="size23"><b>3. 사용예시</b></h3>
<pre id="code_1631193751051" data-ke-language="swift" data-ke-type="codeblock"><code>// interval
let observable = Observable&lt;Int&gt;
                      .interval(.seconds(1), scheduler: MainScheduler.instance)
                      .subscribe { print($0) }
                      
// 직접 해제시켜야함
DispatchQueue.main.asyncAfter(deadline: .now() + 6) {
    observable.dispose()                     
}

// next(1)
// next(2)
// next(3)
// next(4)
// next(5)</code></pre>

<p data-ke-size="size16">interval과 비슷한 operator로 timer가 있는데 이 또한 같이 봐보자.&nbsp;</p>

<h2 data-ke-size="size26"><b>Timer</b></h2>
<h3 data-ke-size="size23"><b>1. 정의</b></h3>
<p data-ke-size="size16">주어진 시간만큼 지난 이후 개별적으로 반환되는 옵저버블을 생성한다.</p>
<figure data-origin-width="1280" data-origin-height="400" width="700" height="219" data-ke-mobilestyle="widthOrigin"><span data-url="https://blog.kakaocdn.net/dn/bkMYRd/btreB9pubCi/wQK9KR6Vcvbi5M29DkVxC0/img.png" data-lightbox="lightbox" data-alt="Timer"><img src="https://blog.kakaocdn.net/dn/bkMYRd/btreB9pubCi/wQK9KR6Vcvbi5M29DkVxC0/img.png" data-origin-width="1280" data-origin-height="400" width="700" height="219" data-ke-mobilestyle="widthOrigin"></span><figcaption>Timer</figcaption></figure>
<p data-ke-size="size16">구독 이후에 딜레이를 가지고 옵저버블이 반환되는 것을 볼 수 있다. 또한 Interval과는 달리 유한한 시퀀스이다.&nbsp;</p>
<h3 data-ke-size="size23"><b>2. 구현</b></h3>
<pre id="code_1631194135089" data-ke-language="swift" data-ke-type="codeblock"><code>public static func timer(_ dueTime: RxTimeInterval, period: RxTimeInterval? = nil, scheduler: SchedulerType) -&gt; Observable&lt;Element&gt; {
    return Timer(
        dueTime: dueTime,
        period: period,
        scheduler: scheduler
    )
}</code></pre>
<p data-ke-size="size16">파라미터를 봐보자. interval과 유사해보이나 조금 다르다.&nbsp;</p>

<ul data-ke-list-type="disc">
<li>dueTime : 첫 번째 값이 생성되기 까지의 상대적인 시간</li>
<li>period : 다음 값이 생성되기 까지의 주기</li>
<li>scheduler : 타이머가 작동될 스케줄러&nbsp;</li>
</ul>
<p data-ke-size="size16">즉, dueTime이 5초라면, 구독하고 나서 5초 뒤에 첫 번째 값을 받아볼 수 있는 것이다. 그리고 period를 보면 기본적으로 nil로 선언되어있음을 볼 수 있다. 따로 설정하지 않으면 다음 값을 뱉지 않는다고 봐도 된다. 스케줄러는 위에서 봤던대로 동일하다.&nbsp;</p>
<h3 data-ke-size="size23"><b>3. 사용 예시</b></h3>
<pre id="code_1631194414620" data-ke-language="swift" data-ke-type="codeblock"><code>// timer
Observable&lt;Int&gt;
    .timer(.seconds(1), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)
        
        
// next(0)
// completed

// timer with period
Observable&lt;Int&gt;
    .timer(.seconds(1), period: .seconds(1), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// next(0)
// next(1)
// next(2)
// next(3)
// next(4)
//    :</code></pre>
<p data-ke-size="size16">interval에서의 seconds와 달리 여기서는 dueTime으로 전달된다. 즉 얼마나 지연시키고 첫 값을 받을지 정해주는 것이다. 위에서는 1초 기다렸다가 첫 번째 값을 받게 되는 것이다. 그리고 timer는 interval과 달리 complete 된다는 점!</p>

<p data-ke-size="size16">period가 timer에 전달된다면, interval과 마찬가지로 직접 종료시켜줘야 한다. 위 코드는 1초 기다렸다가 매 1초간 값을 내뱉는 경우가 되는 것이다. disposeBag에 담았으니 일괄 종료 처리해줘도 되고, 개별적으로 dispose() 해줘도 된다.</p>

<hr contenteditable="false" data-ke-type="horizontalRule" data-ke-style="style5">
<p data-ke-size="size16">Ref :</p>
<p data-ke-size="size16"><a href="http://reactivex.io/documentation/operators/interval.html" target="_blank" rel="noopener">http://reactivex.io/documentation/operators/interval.html</a></p>
<figure id="og_1631194828910" contenteditable="false" data-ke-type="opengraph" data-ke-align="alignCenter" data-og-type="website" data-og-title="ReactiveX - Interval operator" data-og-description="RxGroovy implements this operator as interval. It accepts as its parameters a span of time to wait between emissions and the TimeUnit in which this span is measured. There is also a version of interval that returns an Observable that emits a single zero af" data-og-host="reactivex.io" data-og-source-url="http://reactivex.io/documentation/operators/interval.html" data-og-url="http://reactivex.io/documentation/operators/interval.html" data-og-image=""><a href="http://reactivex.io/documentation/operators/interval.html" target="_blank" rel="noopener" data-source-url="http://reactivex.io/documentation/operators/interval.html">

<div>
<p data-ke-size="size16">ReactiveX - Interval operator</p>
<p data-ke-size="size16">RxGroovy implements this operator as interval. It accepts as its parameters a span of time to wait between emissions and the TimeUnit in which this span is measured. There is also a version of interval that returns an Observable that emits a single zero af</p>
<p data-ke-size="size16">reactivex.io</p>
</div>
</a></figure>

<p data-ke-size="size16"><a href="http://reactivex.io/documentation/operators/timer.html" target="_blank" rel="noopener">http://reactivex.io/documentation/operators/timer.html</a></p>
<figure id="og_1631194823793" contenteditable="false" data-ke-type="opengraph" data-ke-align="alignCenter" data-og-type="website" data-og-title="ReactiveX - Timer operator" data-og-description="In RxJS there are two versions of the timer operator. The first version of timer returns an Observable that emits a single item after a delay period you specify. You can specify the delay either as a Date object (which means, delay until that absolute mome" data-og-host="reactivex.io" data-og-source-url="http://reactivex.io/documentation/operators/timer.html" data-og-url="http://reactivex.io/documentation/operators/timer.html" data-og-image=""><a href="http://reactivex.io/documentation/operators/timer.html" target="_blank" rel="noopener" data-source-url="http://reactivex.io/documentation/operators/timer.html">

<div>
<p data-ke-size="size16">ReactiveX - Timer operator</p>
<p data-ke-size="size16">In RxJS there are two versions of the timer operator. The first version of timer returns an Observable that emits a single item after a delay period you specify. You can specify the delay either as a Date object (which means, delay until that absolute mome</p>
<p data-ke-size="size16">reactivex.io</p>
</div>
</a></figure>
<p data-ke-size="size16"><a href="https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift" target="_blank" rel="noopener">https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift</a></p>
<figure id="og_1631194853168" contenteditable="false" data-ke-type="opengraph" data-ke-align="alignCenter" data-og-type="object" data-og-title="GitHub - ReactiveX/RxSwift: Reactive Programming in Swift" data-og-description="Reactive Programming in Swift. Contribute to ReactiveX/RxSwift development by creating an account on GitHub." data-og-host="github.com" data-og-source-url="https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift" data-og-url="https://github.com/ReactiveX/RxSwift" data-og-image="https://scrap.kakaocdn.net/dn/q391b/hyLyW32XRw/KwcVaBCgKrlsSV4jirwNH0/img.jpg?width=1280&amp;height=640&amp;face=0_0_1280_640"><a href="https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift" target="_blank" rel="noopener" data-source-url="https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift">

<div>
<p data-ke-size="size16">GitHub - ReactiveX/RxSwift: Reactive Programming in Swift</p>
<p data-ke-size="size16">Reactive Programming in Swift. Contribute to ReactiveX/RxSwift development by creating an account on GitHub.</p>
<p data-ke-size="size16">github.com</p>
</div>
</a><img src="https://scrap.kakaocdn.net/dn/q391b/hyLyW32XRw/KwcVaBCgKrlsSV4jirwNH0/img.jpg?width=1280&amp;height=640&amp;face=0_0_1280_640"></figure>
                        </div></div>

참신러닝(Fresh - Learning)

Creating에 속하는 Interval operator에 대해서 알아볼 것이다. 
Interval
1. 정의
주어진 시간 간격을 두고 주기마다, emit되는 옵저버블을 생성한다. Interval 연산자의 경우 completed 되지 않고, 무한한 시퀀스를 생성한다. 즉, 직접 dispose 시키지 않는다면 구독 이후에 계속 반복되는 것이다!
2. 구현
Observables의 Timer에서 구현 내용을 살펴볼 수 있다. 
public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType) -> Observable<Element> {
    return Timer(
        dueTime: period,
        period: period,
        scheduler: scheduler
    )
}
파라미터를 살펴보자.
period : 주기를 의미한다. 1초로 설정하면 1초마다 옵저버블을 반한하게 되는 것이다
scheduler : 작업을 수행할 스케줄러를 고른다. 
3. 사용예시
// interval
let observable = Observable<Int>
                      .interval(.seconds(1), scheduler: MainScheduler.instance)
                      .subscribe { print($0) }
                      
// 직접 해제시켜야함
DispatchQueue.main.asyncAfter(deadline: .now() + 6) {
    observable.dispose()                     
}
// next(1)
// next(2)
// next(3)
// next(4)
// next(5)
 
interval과 비슷한 operator로 timer가 있는데 이 또한 같이 봐보자. 
 
Timer
1. 정의
주어진 시간만큼 지난 이후 개별적으로 반환되는 옵저버블을 생성한다.
구독 이후에 딜레이를 가지고 옵저버블이 반환되는 것을 볼 수 있다. 또한 Interval과는 달리 유한한 시퀀스이다. 
2. 구현
public static func timer(_ dueTime: RxTimeInterval, period: RxTimeInterval? = nil, scheduler: SchedulerType) -> Observable<Element> {
    return Timer(
        dueTime: dueTime,
        period: period,
        scheduler: scheduler
    )
}
파라미터를 봐보자. interval과 유사해보이나 조금 다르다. 
 
dueTime : 첫 번째 값이 생성되기 까지의 상대적인 시간
period : 다음 값이 생성되기 까지의 주기
scheduler : 타이머가 작동될 스케줄러 
즉, dueTime이 5초라면, 구독하고 나서 5초 뒤에 첫 번째 값을 받아볼 수 있는 것이다. 그리고 period를 보면 기본적으로 nil로 선언되어있음을 볼 수 있다. 따로 설정하지 않으면 다음 값을 뱉지 않는다고 봐도 된다. 스케줄러는 위에서 봤던대로 동일하다. 
3. 사용 예시
// timer
Observable<Int>
    .timer(.seconds(1), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)
        
        
// next(0)
// completed
// timer with period
Observable<Int>
    .timer(.seconds(1), period: .seconds(1), scheduler: MainScheduler.instance)
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// next(0)
// next(1)
// next(2)
// next(3)
// next(4)
//    :
interval에서의 seconds와 달리 여기서는 dueTime으로 전달된다. 즉 얼마나 지연시키고 첫 값을 받을지 정해주는 것이다. 위에서는 1초 기다렸다가 첫 번째 값을 받게 되는 것이다. 그리고 timer는 interval과 달리 complete 된다는 점!
 
period가 timer에 전달된다면, interval과 마찬가지로 직접 종료시켜줘야 한다. 위 코드는 1초 기다렸다가 매 1초간 값을 내뱉는 경우가 되는 것이다. disposeBag에 담았으니 일괄 종료 처리해줘도 되고, 개별적으로 dispose() 해줘도 된다.
 
Ref :
http://reactivex.io/documentation/operators/interval.html
 
http://reactivex.io/documentation/operators/timer.html
https://github.com/ReactiveX/RxSwift/blob/main/RxSwift/Observables/Timer.swift

[RxSwift] Operators - Interval, timer

댓글