在akka-alpakka工具包里也提供了对MongoDB的stream-connector，能针对MongoDB数据库进行streaming操作。这个MongoDB-connector里包含了MongoSource，MongoFlow，MongoSink。我们只使用MongoSource，其它两个我们直接用mapAsyc来创造。下面是MongoSource的定义：
object MongoSource { def apply(query: Observable[Document]): Source[Document, NotUsed] = Source.fromPublisher(ObservableToPublisher(query)) }