Monix에서 여러 개의 관찰 된 관찰 가능 항목을 전체적으로 주문하는 방법

Question

주문한 반복기가 여러 개 있다고 가정합니다. 이 반복자를 병합하고 싶으면 (예 : [(1,3,4), (2,4,5)] -> [1,2,3,4,4,5]) monix을 사용하면 어떻게 할 수 있습니까?

Answer 1

이 Monix를 사용하지 않습니다, 그러나 그것은 관련이 있는지 잘 모르겠어요

import scala.collection.BufferedIterator 


def merge[A:Ordering](xs: Seq[Iterator[A]]) = 
    new Iterator[A] { 
    val its = xs.map(_.buffered) 
    def hasNext = its.exists(_.hasNext) 
    def next = its.filter{ _.hasNext} 
        .minBy(_.head) 
        .next 
    } 


val ys = merge(Seq(List(1,3,5).toIterator, List(2,4,6).toIterator, List(10,11).toIterator)) 

ys.toList //> res0: List[Int] = List(1, 2, 3, 4, 5, 6, 10, 11)