Empty

์ œ๋„ค๋ฆญ ๊ตฌ์กฐ์ฒด | ์–ด๋– ํ•œ ๊ฐ’๋„ ์ ˆ๋Œ€ ๋ฐœํ–‰ํ•˜์ง€ ์•Š์œผ๋ฉฐ, ์„ ํƒ์ ์œผ๋กœ ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๋Š” Publisher

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

  • init(completeImmediately:)

    • ์ธ์ž์˜ ๊ธฐ๋ณธ๊ฐ’์€ true์ด๋‹ค.

    • ์ธ์ž์˜ ๊ฐ’์ด true์ด๋ฉด ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๊ณ , false์ด๋ฉด ์ข…๋ฃŒํ•˜์ง€ ์•Š๋Š”๋‹ค.

  • init(completeImmediately:outputType:failureType)

    • completeImmediately ์ธ์ž์˜ ๊ธฐ๋ณธ๊ฐ’์€ true์ด๋ฉฐ, ๊ฐ’์— ๋”ฐ๋ฅธ ๋™์ž‘ ๋ณ€ํ™”๋Š” ์œ„์™€ ๊ฐ™๋‹ค.

    • outputType๊ณผ failureType์€ ํ•ด๋‹น Publisher๋ฅผ Subscriber๋‚˜ ๋‹ค๋ฅธ Publisher์™€ ์—ฐ๊ฒฐํ•  ๋•Œ ์—ฐ๊ฒฐํ•  ๋Œ€์ƒ์˜ Output ํƒ€์ž…๊ณผ ์—๋Ÿฌ ํƒ€์ž…์„ ๋งž์ถ”๊ธฐ ์œ„ํ•ด ๋ช…์‹œํ•ด ์ค€๋‹ค.

      • ๊ทธ๋Ÿฌ๋ฏ€๋กœ ์ธ์ž์— ๋ฉ”ํƒ€ ํƒ€์ž…์„ ์ „๋‹ฌํ•œ๋‹ค.

๊ฐ’์„ ์ „๋‹ฌํ•˜๊ณ  ์‹ถ์ง€ ์•Š์œผ๋ฉฐ, ์ฆ‰์‹œ ์ข…๋ฃŒํ•˜๊ฑฐ๋‚˜ ์ข…๋ฃŒํ•˜์ง€ ์•Š๋Š” Publisher๋ฅผ ๋งŒ๋“ค๊ณ  ์‹ถ์„ ๋•Œ ์‚ฌ์šฉํ•œ๋‹ค.

// completeImmediately: true
Empty<Void, Never>()
  .sink(receiveCompletion: { _ in print("Combine Empty Finish") }, receiveValue: { })
  .store(in: &cancellables)

// Combine Empty Finish

// completeImmediately: false
Empty<Void, Never>(completeImmediately: false)
  .sink(receiveCompletion: { _ in print("Combine Never Finish") }, receiveValue: { })
  .store(in: &cancellables)

// ์•„๋ฌด๊ฒƒ๋„ ์ถœ๋ ฅ๋˜์ง€ ์•Š์Œ

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

1๋ฒˆ ์ฝ”๋“œ์˜ ๊ฒฝ์šฐ Publisher๊ฐ€ ๋ฐ”๋กœ ์ข…๋ฃŒํ•˜์—ฌ receiveCompletion์— ๋“ฑ๋กํ•œ ํด๋กœ์ €๊ฐ€ ์‹คํ–‰๋˜๋Š” ๊ฒƒ์„ ํ™•์ธํ•  ์ˆ˜ ์žˆ๋‹ค.

2๋ฒˆ ์ฝ”๋“œ์˜ ๊ฒฝ์šฐ Publisher๊ฐ€ ์ข…๋ฃŒํ•˜์ง€ ์•Š์œผ๋ฏ€๋กœ ์•„๋ฌด๋Ÿฐ ์ถœ๋ ฅ๋„ ํ™•์ธํ•  ์ˆ˜ ์—†๋‹ค.

RxSwift

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

  • empty ์˜คํผ๋ ˆ์ดํ„ฐ๋Š” Empty(completeImmediately: true)์˜ ๋™์ž‘๊ณผ ๊ฐ™๋‹ค.

  • never ์˜คํผ๋ ˆ์ดํ„ฐ๋Š” Empty(completeImmediately: false)์˜ ๋™์ž‘๊ณผ ๊ฐ™๋‹ค.

// empty Operator
Observable<Void>.empty()
  .subscribe(onCompleted: { print("RxSwift Empty Finish") })
  .disposed(by: disposeBag)

// RxSwift Empty Finish

// never Operator
Observable<Void>.never()
  .subscribe(onCompleted: { print("RxSwift Never Finish" )})
  .disposed(by: disposeBag)

// ์•„๋ฌด๊ฒƒ๋„ ์ถœ๋ ฅ๋˜์ง€ ์•Š์Œ

ReactiveSwift

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

  • empty ์˜คํผ๋ ˆ์ดํ„ฐ๋Š” Empty(completeImmediately: true)์˜ ๋™์ž‘๊ณผ ๊ฐ™๋‹ค.

  • never ์˜คํผ๋ ˆ์ดํ„ฐ๋Š” Empty(completeImmediately: false)์˜ ๋™์ž‘๊ณผ ๊ฐ™๋‹ค.

// empty Operator
SignalProducer<Void, Never>.empty
  .startWithCompleted { print("ReactiveSwift Empty Finish") }

// ReactiveSwift Empty Finish

// never Operator
SignalProducer<Void, Never>.never
  .startWithCompleted { print("ReactiveSwift Never Finish") }
ใ„น6 ใ„ฑ5ใ…‡ใ„ท4ใ„ดใ…ˆ333ใ…‡ใ„ท4ใ…ˆ2
// ์•„๋ฌด๊ฒƒ๋„ ์ถœ๋ ฅ๋˜์ง€ ์•Š์Œ

์ฐธ๊ณ 

ReactiveX - Operators - Empty | Never

Last updated

Was this helpful?