zip은 두 개 이상의 Publisher를 조합하여 각 Publisher에서 발행되는 값을 쌍으로 묶는데에 사용돼요.

기능

• 각 Publisher 로부터 발행되는 값들을 순서대로 쌍으로 묶어 Tuple로 결합해요.
• 쌍으로 묶기 때문에 쌍이 성립하지 않으면 발행되지 않아요
  • 예를들면 3개의 publisher가 zip으로 묶였을 때 한 개의 publisher가 값을 발행하지 않았다면 값이 발행되지 않아요.
• 이러한 특성 때문에 비동기 데이터 스트림의 동기화 지점으로 많이 사용돼요.
• zip으로 한번에 묶을 수 있는 최대값은 4개에요.

사용

let publisher1 = PassthroughSubject<String, Never>()
let publisher2 = PassthroughSubject<String, Never>()
let publisher3 = PassthroughSubject<String, Never>()

Publishers.Zip3(publisher1, publisher2, publisher3)
  .sink { (pubValue1, pubValue2, pubValue3) in
    print("\\(pubValue1), \\(pubValue2), \\(pubValue3)")
  }
  .store(in: &cancellables)

publisher1.send("1")
publisher2.send("2")
publisher3.send("3")

// 결과
1, 2, 3

⚠️ 만약 여기서 한개의 publisher라도 값을 발행하지 않으면 발행되지 않아요.

let publisher1 = PassthroughSubject<String, Never>()
let publisher2 = PassthroughSubject<String, Never>()
let publisher3 = PassthroughSubject<String, Never>()

Publishers.Zip3(publisher1, publisher2, publisher3)
  .sink { (pubValue1, pubValue2, pubValue3) in
    print("\\(pubValue1), \\(pubValue2), \\(pubValue3)")
  }
  .store(in: &cancellables)

publisher1.send("1")
publisher2.send("2")
//publisher3.send("3")

// 결과
(결과없음)

⚠️ 쌍을 이루지 않는 publisher의 값 역시 발행되지 않아요.

let publisher1 = PassthroughSubject<String, Never>()
let publisher2 = PassthroughSubject<String, Never>()
let publisher3 = PassthroughSubject<String, Never>()

Publishers.Zip3(publisher1, publisher2, publisher3)
  .sink { (pubValue1, pubValue2, pubValue3) in
    print("\\(pubValue1), \\(pubValue2), \\(pubValue3)")
  }
  .store(in: &cancellables)

publisher1.send("1")
publisher2.send("2")
publisher3.send("3")

publisher1.send("4")

// 결과
1, 2, 3

publisher1,2,3에서 발행한 값들은 정상 발행시 소진되기 때문에

publisher1에서 새로발행한 4는 다른 publisher가 쌍을 이룰 수 있게 값을 내지 않으면 발행되지 않아요.