Publishers.LastWhere

제네릭 구조체 | 스트림이 종료하면, 특정 조건 클로저를 만족하기 위한 스트림의 마지막 요소만을 발행하는 Publisher

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

• upstream : 상위에 흐르는 Publisher

• predicate : 어떤 요소를 발행할지 결정하는 클로저

상위 Publisher로부터 조건 클로저에 만족하는 요소를 먼저 뽑아내고, 그 중에서 마지막 요소만을 발행한다.

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

// Publishers.LastWhere Publisher
Publishers
  .LastWhere(upstream: Publishers.Sequence<[Int], Never>(sequence: [1, 2, 3, 4, 5])) { !$0.isMultiple(of: 2) }
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine FirstWhere Error")
    case .finished:
      print("Combine FirstWhere Finish")
    }
  }, receiveValue: { value in
    print("Combine FirstWhere : \(value)")
  })
  .store(in: &cancellables)

// last Operator
Publishers.Sequence<[Int], Never>(sequence: [1, 2, 3, 4, 5])
  .last { !$0.isMultiple(of: 2) }
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine FirstWhere Error")
    case .finished:
      print("Combine FirstWhere Finish")
    }
  }, receiveValue: { value in
    print("Combine FirstWhere : \(value)")
  })
  .store(in: &cancellables)

// Combine LastWhere : 5
// Combine LastWhere Finish

상위 Publisher는 1, 2, 3, 4, 5의 값을 차례대로 내고, 2의 배수가 아닌 조건을 설정했다.

값들 중 2의 배수가 아닌 1, 3, 5 중 마지막 요소는 5이므로, 최종적으로 5의 값을 내고 종료한다.

RxSwift

해당 동작을 구현하기 위한 오퍼레이터를 제공하지 않는다.

ReactiveSwift

해당 동작을 구현하기 위한 오퍼레이터를 제공하지 않는다.