上流整合類型由於沒辦法直接用 Sequence.Publisher 的方式測試, 這部分的 Demo code 將於日後更新.

6-1. zip: 等待不同的上游發佈, 只有指定的所有上游發佈後, 再一次發佈組合後的元素, 當任一上游發佈結束時, 會立即發佈結束.

用 zip(,) 想會不會好一些呢?

/******demo code*******/

Publishers.Zip(
            (1...5).publisher,
            (6...10).publisher)
            .sink{print("get value:", $0)}

/******console*********/

get value: (1, 6)
get value: (2, 7)
get value: (3, 8)
get value: (4, 9)
get value: (5, 10)

/*******Rarbles********/

-----1-----2-----3-----4-----5-----|
  -----6-----7-----8-----9-----10-----|
  
              zip
              
-------1-----2-----3-----4-----5------|
       6     7     8     9     10

6-2. combineLatest: 相似與 zip, 一旦所有上游發佈過後, 才會發佈第一次, 而後續只要任一上游發佈, 就會將所有上游最新的元素組合發佈.

/*******Rarbles********/

-----1-----2-----3-----|
  -----------6------8-----9-----10-----|
  
  combineLatest
  
-------------2---3--3-----3-----3-------|
             6   6  8     9     10

6-3. merge: 將指定多個上游的元素轉發, 需要所有上游的 Output 與 Failure 都相符

/*******Rarbles********/

-----1-----2-----3-----|
  -----6-----------8-----9-----10-----|
  
      merge
  
-----1-6---2-----3-8-----9-----10-----|