Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

6.  def deleteMany[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Sink[Bson, Future[Done]]

   A Sink that will delete many documents as defined by a Bson filter query.

   A Sink that will delete many documents as defined by a Bson filter query.

   collection

   the mongo db collection to update.

   options

   options to apply to the operation

7.  def deleteOne[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Sink[Bson, Future[Done]]

   A Sink that will delete individual documents as defined by a Bson filter query.

   A Sink that will delete individual documents as defined by a Bson filter query.

   collection

   the mongo db collection to update.

   options

   options to apply to the operation

8.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

9.  def equals(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef → Any

10.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

11.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

13.  def insertMany[T](collection: MongoCollection[T], options: InsertManyOptions = DefaultInsertManyOptions): Sink[Seq[T], Future[Done]]

    A Sink that will insert batches of documents into a collection.

    A Sink that will insert batches of documents into a collection.

    collection

    mongo db collection to insert to.

    options

    options to apply to the operation

14.  def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions = DefaultInsertOneOptions): Sink[T, Future[Done]]

    A Sink that will insert documents into a collection.

    A Sink that will insert documents into a collection.

    collection

    mongo db collection to insert to.

    options

    options to apply to the operation

15.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

16.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

17.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

18.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

19.  def replaceOne[T](collection: MongoCollection[T], options: ReplaceOptions = DefaultReplaceOptions): Sink[DocumentReplace[T], Future[Done]]

    A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.

    A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.

    collection

    the mongo db collection to update.

    options

    options to apply to the operation

20.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

21.  def toString(): String

    Definition Classes

    AnyRef → Any

22.  def updateMany[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Sink[DocumentUpdate, Future[Done]]

    A Sink that will update many documents as defined by a DocumentUpdate.

    A Sink that will update many documents as defined by a DocumentUpdate.

    collection

    the mongo db collection to update.

    options

    options to apply to the operation

23.  def updateOne[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Sink[DocumentUpdate, Future[Done]]

    A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.

    A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.

    collection

    the mongo db collection to update.

    options

    options to apply to the operation

24.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

25.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

26.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()