Publishers.Collect

제네릭 구조체 | 아이템을 일시적으로 기억하는 Publisher

이니셜라이저는 한 개의 인자를 받는다.

• upstream : 상위에 흐르는 Publisher

값을 받을 때마다 동작하지 않고, 에러 또는 종료 이벤트가 날 때까지 값을 기억해 두었다가 배열의 형태로 값을 한꺼번에 낸다.

에러를 내면 그 시점까지 모아 놓은 값들 대신 에러를 낸다.

종료를 내면 그 시점까지 모아 놓은 값들을 배열의 형태로 한꺼번에 낸다.

collect 오퍼레이터와 관련이 있다.

let subject = PassthroughSubject<Int, Error>()

// Publishers.Collect Publisher
 Publishers.Collect(upstream: subject)
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine Collect Error")
    case .finished:
      print("Combine Collect Finish")
    }
  }, receiveValue: { value in
    print("Combine Collect : \(value)")
  })
  .store(in: &cancellables)

// collect Operator
subject
  .collect()
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine Collect Error")
    case .finished:
      print("Combine Collect Finish")
    }
  }, receiveValue: { value in
    print("Combine Collect : \(value)")
  })
  .store(in: &cancellables)

// 1
subject.send(1)
subject.send(2)
subject.send(completion: .finished)

// Combine Collect : [1, 2]
// Combine Collect Finish

// 2
subject.send(1)
subject.send(completion: .failure(error))

// Combine Collect Error

1의 경우 완료 이벤트를 내기까지 전달된 1, 2의 값이 배열의 형태로 묶여 한번에 발행된다.

2의 경우 에러로 인해 종료했기 때문에 결과적으로 에러를 낸다.

RxSwift

toArray 오퍼레이터를 사용하여 구현할 수 있다.

let subject = PublishSubject<Int>()

subject
  .toArray()
  .subscribe(onSuccess: { value in
    print("RxSwift Collect : \(value)")
  }, onError: { _ in
    print("RxSwift Collect Error")
  })
  .disposed(by: disposeBag)

subject.onNext(1)
subject.onNext(2)
subject.onCompleted()

// RxSwift Collect : [1, 2]

ReactiveSwift

collect 오퍼레이터를 사용하여 구현할 수 있다.

let property = MutableProperty<Int>(0)

property.signal
  .collect()
  .observe { event in
    switch event {
    case let .value(value):
      print("ReactiveSwift Collect : \(value)")
    case .failed:
      print("ReactiveSwift Collect Error")
    case .completed:
      print("ReactiveSwift Collect Finish")
    default:
      break
    }
  }

property.value = 1
property.value = 2

// ReactiveSwift Collect : [1, 2]
// ReactiveSwift Collect Finish

참고

ReactiveX - Operators - To