Ничто не приходит в Раковину, определенную также

Question

Кроме того, кажется, не работает для меня. Предметы не приходят в тонуть, определенные в нем. Вот что у меня есть.

val merged: Source[ArticleWithKeywords, _] =  ...
val (ks, fut) = merged
  .alsoTo(Flow[ArticleWithKeywords].map { a => a.id -> a.ids.toList }.to(queueManager.getIdsForAnsSink))
  .map(_.id)
  .groupedWithin(100, 5 seconds)
  .mapAsync(4) { ids => runReferenceFetching(ids) }
  .viaMat(KillSwitches.single)(Keep.right)
  .toMat(Sink.ignore)(Keep.both)
  .run()

Но я вижу элементы, достигающие runReferenceFetching. Что мне не хватает?

Answer 1

Оказалось, проблема не имеет ничего общего с alsoTo, Проблема была с раковиной, которая была создана с помощью Source.fromPublisher, Я ошибочно думал, что могу создать несколько раковин, используя один и тот же Publisher[T], Так как уже была другая раковина, вторая не работала.