Fail

์ œ๋„ค๋ฆญ ๊ตฌ์กฐ์ฒด | ํŠน์ • ์—๋Ÿฌ์™€ ํ•จ๊ป˜ ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๋Š” Publisher

๋‘ ๊ฐœ์˜ ์ด๋‹ˆ์…œ๋ผ์ด์ €๋ฅผ ์ œ๊ณตํ•œ๋‹ค.

  • init(error:)

    • Error ํ”„๋กœํ† ์ฝœ์„ ์ฑ„ํƒํ•˜๋Š” ๊ฐ’์„ error ์ธ์ž์— ๋„˜๊ฒจ์ฃผ์–ด ํ•ด๋‹น ์—๋Ÿฌ๋ฅผ ๋‚ด๊ณ  ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๋Š” Publisher๋ฅผ ๋งŒ๋“ ๋‹ค.

  • init(outputType:failure:)

    • Error ํ”„๋กœํ† ์ฝœ์„ ์ฑ„ํƒํ•˜๋Š” ๊ฐ’์„ failure ์ธ์ž์— ๋„˜๊ฒจ์ฃผ์–ด ํ•ด๋‹น ์—๋Ÿฌ๋ฅผ ๋‚ด๊ณ  ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๋Š” Publisher๋ฅผ ๋งŒ๋“ ๋‹ค.

    • outputType์—๋Š” ํŠน์ • Output ํƒ€์ž…์„ ๊ฐ€์ง„ Subscriber์™€ Publisher์™€ ํ•จ๊ป˜ ๋™์ž‘ํ•ด์•ผ ํ•  ๋•Œ Output ํƒ€์ž…์˜ ๋ฉ”ํƒ€ ํƒ€์ž…์„ ๋„˜๊ฒจ์ค€๋‹ค.

Just๊ฐ€ ํŠน์ • ๊ฐ’์„ ๋‚ด๋ ค์ฃผ๊ณ  ์ข…๋ฃŒํ•œ๋‹ค๋ฉด, Fail์€ ํŠน์ • ์—๋Ÿฌ์™€ ํ•จ๊ป˜ ์ฆ‰์‹œ ์ข…๋ฃŒํ•œ๋‹ค.

Fail(error: error)
  .sink(receiveCompletion: { _ in print("Combine Fail Error") }, receiveValue: { })
  .store(in: &cancellables)

// Combine Fail Error

Emtpy๋Š” ๊ฐ’์„ ๋‚ด์ง€ ์•Š์œผ๋ฏ€๋กœ receiveValue ํด๋กœ์ €์—์„œ๋Š” ๋™์ž‘์„ ํ™•์ธํ•  ์ˆ˜ ์—†๊ณ , receiveCompletion ํด๋กœ์ €์—์„œ ์ข…๋ฃŒํ•˜๋Š” ๋™์ž‘์„ ํ™•์ธํ•  ์ˆ˜ ์žˆ๋‹ค.

RxSwift

error ์˜คํผ๋ ˆ์ดํ„ฐ๋ฅผ ์‚ฌ์šฉํ•˜์—ฌ ๊ตฌํ˜„ํ•  ์ˆ˜ ์žˆ๋‹ค.

Observable<Void>.error(error)
  .subscribe(onError: { _ in print("RxSwift Fail Error") })
  .disposed(by: disposeBag)

// RxSwift Fail Error

ReactiveSwift

init(error:) ์ด๋‹ˆ์…œ๋ผ์ด์ €๋ฅผ ์‚ฌ์šฉํ•˜์—ฌ ๊ตฌํ˜„ํ•  ์ˆ˜ ์žˆ๋‹ค.

SignalProducer<Void, Error>(error: error)
  .startWithFailed { _ in print("ReactiveSwift Fail Error") }

// ReactiveSwift Fail Error

Combine๊ณผ ๊ฐ™์ด ๊ฐ’์„ ๋‚ด์ง€ ์•Š์œผ๋ฏ€๋กœ startWithValues ๋ฉ”์†Œ๋“œ๋ฅผ ์‚ฌ์šฉํ•˜๋ฉด ๋™์ž‘์„ ํ™•์ธํ•  ์ˆ˜ ์—†๊ณ , startWithFailed ๋ฉ”์†Œ๋“œ๋ฅผ ์‚ฌ์šฉํ•˜์—ฌ ์—๋Ÿฌ๋ฅผ ๋‚ด๋Š” ๋™์ž‘์„ ํ™•์ธํ•  ์ˆ˜ ์žˆ๋‹ค.

์ฐธ๊ณ 

ReactiveX - Operators - Throw

Last updated

Was this helpful?