Alpakka MongoDB -覆盖MongoSource实现

Question

我有类似于Alpakka MongoDB - specify type in MongoSource 的问题

因此，我实现了我自己的MongoSource，就像在解决方案中一样，并使用它：

object MyMongoSource {
  def apply[T](query: Observable[T]): Source[T, NotUsed] =
    Source.fromPublisher(ObservableToPublisher(query))
}

val source: Source[Book, NotUsed] = MyMongoSource[Book](mongoDb.books.find()) 

但是ObservableToPublisher是private class，所以我得到以下错误：

object ObservableToPublisher in package mongodb cannot be accessed in package akka.stream.alpakka.mongodb

如何解决这个问题？

Answer 1

将MyMongoSource定义为在akka.stream.alpakka.mongodb.scaladsl包中：

package akka.stream.alpakka.mongodb.scaladsl

import akka.NotUsed
import akka.stream.alpakka.mongodb.ObservableToPublisher
import akka.stream.scaladsl.Source
import org.mongodb.scala.Observable

object MyMongoSource {
  def apply[T](query: Observable[T]): Source[T, NotUsed] =
    Source.fromPublisher(ObservableToPublisher(query))
}