Соедините второй перечислитель с Concurrent.broadcast

Question

Я пытаюсь вставить счетчик коллекции Монгоса в существующий перечислитель Concurrent.broadcast. Является ли это возможным? Или есть лучший способ?

Главная переписчик:

val (event, eventChannel) = Concurrent.broadcast[JsValue] 

и моя коллекция ограничен наблюдающий:

def watcher : Enumerator[JsObject] = { 
     val futureEnumerator = collection.map { collection => 
     val cursor: Cursor[JsObject] = collection 
      .find(Json.obj()) 
      .options(QueryOpts().tailable.awaitData) 
      .cursor[JsObject] 
     cursor.enumerate() 
     } 
     Enumerator.flatten(futureEnumerator) 
    } 

Answer 1

То, что я искал это >-:

val combinedStreams = event >- watcher