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


<h3 data-ke-size="size23"><b>1. 정의&nbsp;</b></h3>
<p data-ke-size="size16">empty는 아무 것도 emit하지 않는 옵저버블을 생성하지만 정상적으로 종료시킨다.&nbsp;</p>

<figure data-origin-width="1280" data-origin-height="380" width="600" height="178" data-ke-mobilestyle="widthOrigin"><span data-url="https://blog.kakaocdn.net/dn/bSs9r4/btrevY8BxOU/vALx16bhHn2peSluAaqsKk/img.png" data-lightbox="lightbox" data-alt="Empty"><img src="https://blog.kakaocdn.net/dn/bSs9r4/btrevY8BxOU/vALx16bhHn2peSluAaqsKk/img.png" data-origin-width="1280" data-origin-height="380" width="600" height="178" data-ke-mobilestyle="widthOrigin"></span><figcaption>Empty</figcaption></figure>
<p data-ke-size="size16">즉, 그냥 빈 값으로 종료만 시키는 것!</p>
<h3 data-ke-size="size23"><b>2. 구현부</b></h3>
<pre id="code_1631087223462" data-ke-language="swift" data-ke-type="codeblock"><code>public static func empty() -&gt; Observable&lt;Element&gt; {
    EmptyProducer&lt;Element&gt;()
}

final private class EmptyProducer&lt;Element&gt;: Producer&lt;Element&gt; {
    override func subscribe&lt;Observer: ObserverType&gt;(_ observer: Observer) -&gt; Disposable where Observer.Element == Element {
        observer.on(.completed)
        return Disposables.create()
    }
}</code></pre>
<p data-ke-size="size16">EmptyProducer에서 보면 onCompleted 처리를 해주고 있는 것을 볼 수 있다.&nbsp;</p>

<h3 data-ke-size="size23"><b>3. 사용 예시</b></h3>
<pre id="code_1631087474272" data-ke-language="swift" data-ke-type="codeblock"><code>let observable = Observable&lt;Void&gt;.empty()

observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// completed</code></pre>

<p data-ke-size="size16">즉시 종료되는 옵저버블을 반환하고 싶을 때나, 의도적으로 빈 값을 내뱉도록 하고 싶을 때 사용할 수 있다.&nbsp;</p>


<h2 data-ke-size="size26"><b>Never</b></h2>
<h3 data-ke-size="size23"><b>1. 정의</b></h3>
<p data-ke-size="size16">never은 아무것도 emit하지 않고 종료되지도 않는다. 즉, 무한한 상태이다!</p>
<figure data-origin-width="1280" data-origin-height="370" width="600" height="173" data-ke-mobilestyle="widthOrigin"><span data-url="https://blog.kakaocdn.net/dn/dE5IXx/btreoTBchs1/7ba1esdAIDWtYuf4Wj1DU0/img.png" data-lightbox="lightbox" data-alt="Never"><img src="https://blog.kakaocdn.net/dn/dE5IXx/btreoTBchs1/7ba1esdAIDWtYuf4Wj1DU0/img.png" data-origin-width="1280" data-origin-height="370" width="600" height="173" data-ke-mobilestyle="widthOrigin"></span><figcaption>Never</figcaption></figure>
<p data-ke-size="size16">스트림에 아무런 표시가 없는 걸 볼 수 있다.</p>
<h3 data-ke-size="size23"><b>2. 구현부</b></h3>
<pre id="code_1631087644496" data-ke-language="swift" data-ke-type="codeblock"><code>public static func never() -&gt; Observable&lt;Element&gt; {
    NeverProducer()
}

final private class NeverProducer&lt;Element&gt;: Producer&lt;Element&gt; {
    override func subscribe&lt;Observer: ObserverType&gt;(_ observer: Observer) -&gt; Disposable where Observer.Element == Element {
        Disposables.create()
    }
}</code></pre>

<p data-ke-size="size16">empty와 달리 구현부에 onCompleted가 구현되지 않은 것을 볼 수 있다.&nbsp;</p>
<h3 data-ke-size="size23"><b>3. 사용 예시</b></h3>
<pre id="code_1631087713536" data-ke-language="swift" data-ke-type="codeblock"><code>let observable = Observable&lt;Any&gt;.never()

observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)

// 아무 것도 반환X</code></pre>
<p data-ke-size="size16">이를 subscribe하면 onNext나 onCompleted는 반환(emit)되지 않는다!</p>


<h2 data-ke-size="size26"><b>Error</b></h2>
<h3 data-ke-size="size23"><b>1. 정의</b></h3>
<p data-ke-size="size16">아무것도 emit하지 않고 단일 에러(.error) 이벤트와 함께 종료된다.</p>
<p data-ke-size="size16">(문서에는 throw라고 되어있지만 RxSwift에서는 error가 이에 대응하는 것 같다!)&nbsp;</p>
<figure data-origin-width="2560" data-origin-height="760" width="600" height="178" data-ke-mobilestyle="widthOrigin"><span data-url="https://blog.kakaocdn.net/dn/NileZ/btrevIkEfj3/dTM1Tt8qkgKBjX8jxiJYk1/img.png" data-lightbox="lightbox" data-alt="Error"><img src="https://blog.kakaocdn.net/dn/NileZ/btrevIkEfj3/dTM1Tt8qkgKBjX8jxiJYk1/img.png" data-origin-width="2560" data-origin-height="760" width="600" height="178" data-ke-mobilestyle="widthOrigin"></span><figcaption>Error</figcaption></figure>
<p data-ke-size="size16">스트림에 에러말고는 보이는게 없다!</p>
<h3 data-ke-size="size23"><b>2. 구현부</b></h3>
<pre id="code_1631088069239" data-ke-language="swift" data-ke-type="codeblock"><code>public static func error(_ error: Swift.Error) -&gt; Observable&lt;Element&gt; {
    ErrorProducer(error: error)
}

final private class ErrorProducer&lt;Element&gt;: Producer&lt;Element&gt; {
    private let error: Swift.Error
    
    init(error: Swift.Error) {
        self.error = error
    }
    
    override func subscribe&lt;Observer: ObserverType&gt;(_ observer: Observer) -&gt; Disposable where Observer.Element == Element {
        observer.on(.error(self.error))
        return Disposables.create()
    }
}</code></pre>
<p data-ke-size="size16">onError만 처리하고 있는 것을 볼 수 있다!</p>

<h3 data-ke-size="size23"><b>3. 사용 예시</b></h3>
<pre id="code_1631088406959" data-ke-language="swift" data-ke-type="codeblock"><code>enum CustomError: Error {
	case error
}

let observable = Observable&lt;Void&gt;.error(CustomError.error)

observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// error(error)</code></pre>
<p data-ke-size="size16">데이터 저장과 같은 과정의 실패를 설명하는데 유용하다. (URLSession에서 error 처리해주는 것과 비슷한 느낌!)</p>
<hr contenteditable="false" data-ke-type="horizontalRule" data-ke-style="style5">
<p data-ke-size="size16">Ref :&nbsp;</p>
<p data-ke-size="size16"><a href="http://reactivex.io/documentation/operators/empty-never-throw.html" target="_blank" rel="noopener">http://reactivex.io/documentation/operators/empty-never-throw.html</a></p>
<figure id="og_1631088537828" contenteditable="false" data-ke-type="opengraph" data-ke-align="alignCenter" data-og-type="website" data-og-title="ReactiveX - Empty, Never, and Throw operators" data-og-description="RxGroovy implements these operators as empty, never, and error. The error operator takes as a parameter the Throwable with which you want the Observable to terminate. These operators do not operate by default on any particular Scheduler, but empty and erro" data-og-host="reactivex.io" data-og-source-url="http://reactivex.io/documentation/operators/empty-never-throw.html" data-og-url="http://reactivex.io/documentation/operators/empty-never-throw.html" data-og-image=""><a href="http://reactivex.io/documentation/operators/empty-never-throw.html" target="_blank" rel="noopener" data-source-url="http://reactivex.io/documentation/operators/empty-never-throw.html">

<div>
<p data-ke-size="size16">ReactiveX - Empty, Never, and Throw operators</p>
<p data-ke-size="size16">RxGroovy implements these operators as empty, never, and error. The error operator takes as a parameter the Throwable with which you want the Observable to terminate. These operators do not operate by default on any particular Scheduler, but empty and erro</p>
<p data-ke-size="size16">reactivex.io</p>
</div>
</a></figure>
<p data-ke-size="size16"><a href="https://www.stepintoswift.com/rxswift-operator-error" target="_blank" rel="noopener">https://www.stepintoswift.com/rxswift-operator-error</a></p>
<figure id="og_1631088542724" contenteditable="false" data-ke-type="opengraph" data-ke-align="alignCenter" data-og-type="article" data-og-title="What is the Error Operator in RxSwift?" data-og-description="Error Operator" data-og-host="www.stepintoswift.com" data-og-source-url="https://www.stepintoswift.com/rxswift-operator-error" data-og-url="https://www.stepintoswift.com/rxswift-operator-error" data-og-image=""><a href="https://www.stepintoswift.com/rxswift-operator-error" target="_blank" rel="noopener" data-source-url="https://www.stepintoswift.com/rxswift-operator-error">

<div>
<p data-ke-size="size16">What is the Error Operator in RxSwift?</p>
<p data-ke-size="size16">Error Operator</p>
<p data-ke-size="size16">www.stepintoswift.com</p>
</div>
</a></figure>
                        </div></div>

참신러닝(Fresh - Learning)

Creating에 속하는 empty, never, throw에 대해 알아볼 것이다. 
 
Empty
1. 정의 
empty는 아무 것도 emit하지 않는 옵저버블을 생성하지만 정상적으로 종료시킨다. 
 
즉, 그냥 빈 값으로 종료만 시키는 것!
2. 구현부
public static func empty() -> Observable<Element> {
    EmptyProducer<Element>()
}
final private class EmptyProducer<Element>: Producer<Element> {
    override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
        observer.on(.completed)
        return Disposables.create()
    }
}
EmptyProducer에서 보면 onCompleted 처리를 해주고 있는 것을 볼 수 있다. 
 
3. 사용 예시
let observable = Observable<Void>.empty()
observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// completed
 
즉시 종료되는 옵저버블을 반환하고 싶을 때나, 의도적으로 빈 값을 내뱉도록 하고 싶을 때 사용할 수 있다. 
 
 
Never
1. 정의
never은 아무것도 emit하지 않고 종료되지도 않는다. 즉, 무한한 상태이다!
스트림에 아무런 표시가 없는 걸 볼 수 있다.
2. 구현부
public static func never() -> Observable<Element> {
    NeverProducer()
}
final private class NeverProducer<Element>: Producer<Element> {
    override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
        Disposables.create()
    }
}
 
empty와 달리 구현부에 onCompleted가 구현되지 않은 것을 볼 수 있다. 
3. 사용 예시
let observable = Observable<Any>.never()
observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)
// 아무 것도 반환X
이를 subscribe하면 onNext나 onCompleted는 반환(emit)되지 않는다!
 
 
Error
1. 정의
아무것도 emit하지 않고 단일 에러(.error) 이벤트와 함께 종료된다.
(문서에는 throw라고 되어있지만 RxSwift에서는 error가 이에 대응하는 것 같다!) 
스트림에 에러말고는 보이는게 없다!
2. 구현부
public static func error(_ error: Swift.Error) -> Observable<Element> {
    ErrorProducer(error: error)
}
final private class ErrorProducer<Element>: Producer<Element> {
    private let error: Swift.Error
    
    init(error: Swift.Error) {
        self.error = error
    }
    
    override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
        observer.on(.error(self.error))
        return Disposables.create()
    }
}
onError만 처리하고 있는 것을 볼 수 있다!
 
3. 사용 예시
enum CustomError: Error {
	case error
}
let observable = Observable<Void>.error(CustomError.error)
observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)
    
// error(error)
데이터 저장과 같은 과정의 실패를 설명하는데 유용하다. (URLSession에서 error 처리해주는 것과 비슷한 느낌!)
Ref : 
http://reactivex.io/documentation/operators/empty-never-throw.html
https://www.stepintoswift.com/rxswift-operator-error

[RxSwift] Operators - empty, never, throw

댓글