Как конвертировать реактивный Publisher в простой поток в Scala?

Question

Возможно ли преобразовать org.reactivestreams.Publisher экземпляр в scala.Stream?Если это возможно, как это сделать?

Answer 1

Будет ли что-то подобное для вас работать?

val queue: java.util.concurrent.BlockingQueue[T] = ... // TODO: choose appropriate BlockingQueue implementation

publisher.subscribe(new Subscriber[T] {
  override def onNext(t: T): Unit = { queue.put(t) }

  // TODO: implement other Subscriber methods
}

val stream = Stream.continually(queue.take)