package gridfs
- Alphabetic
- By Inheritance
- gridfs
- ObservableImplicits
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- implicit class BoxedPublisher[T] extends Observable[T]
- Definition Classes
- ObservableImplicits
- implicit class BoxedSubscriber[T] extends Observer[T]
- Definition Classes
- ObservableImplicits
- implicit class BoxedSubscription extends Subscription
- Definition Classes
- ObservableImplicits
- implicit class ObservableFuture[T] extends AnyRef
- Definition Classes
- ObservableImplicits
- implicit class SingleObservableFuture[T] extends AnyRef
- Definition Classes
- ObservableImplicits
- implicit class ToObservableString extends Observable[String]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservableGridFS extends SingleObservable[GridFSFile]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservableInt extends SingleObservable[Int]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservableLong extends SingleObservable[Long]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservableObjectId extends SingleObservable[ObjectId]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservablePublisher[T] extends SingleObservable[T]
- Definition Classes
- ObservableImplicits
- implicit class ToSingleObservableUnit extends SingleObservable[Unit]
An Observable that emits
An Observable that emits
- exactly one item, if the wrapped
Publisher
does not signal an error, even if the represented stream is empty; - no items if the wrapped
Publisher
signals an error.
- Definition Classes
- ObservableImplicits
- exactly one item, if the wrapped
- case class GridFSBucket(wrapped: com.mongodb.reactivestreams.client.gridfs.GridFSBucket) extends Product with Serializable
Represents a GridFS Bucket
Represents a GridFS Bucket
- Since
1.2
- case class GridFSDownloadObservable(wrapped: GridFSDownloadPublisher) extends Observable[ByteBuffer] with Product with Serializable
A GridFS Observable for downloading data from GridFS
A GridFS Observable for downloading data from GridFS
Provides the
GridFSFile
for the file to being downloaded as well as a way to control the batchsize.- Since
2.8
- type GridFSDownloadOptions = com.mongodb.client.gridfs.model.GridFSDownloadOptions
The GridFS download by name options
The GridFS download by name options
Controls the selection of the revision to download
- type GridFSFile = com.mongodb.client.gridfs.model.GridFSFile
The GridFSFile
- case class GridFSFindObservable(wrapped: GridFSFindPublisher) extends Observable[GridFSFile] with Product with Serializable
Observable representing the GridFS Files Collection.
Observable representing the GridFS Files Collection.
- Since
1.2
- case class GridFSUploadObservable[T](wrapped: GridFSUploadPublisher[T]) extends SingleObservable[T] with Product with Serializable
A GridFS
Observable
for uploading data into GridFSA GridFS
Observable
for uploading data into GridFSProvides the
id
for the file to be uploaded. Cancelling the subscription to this publisher will cause any uploaded data to be cleaned up and removed.- T
the result type of the publisher
- Since
2.8
- type GridFSUploadOptions = com.mongodb.client.gridfs.model.GridFSUploadOptions
GridFS upload options
GridFS upload options
Customizable options used when uploading files into GridFS
- type MongoGridFSException = com.mongodb.MongoGridFSException
An exception indicating that a failure occurred in GridFS.
- implicit class ToGridFSUploadPublisherUnit extends GridFSUploadPublisher[Unit]
A
GridFSUploadPublisher
that emits
A
GridFSUploadPublisher
that emits
- exactly one item, if the wrapped
Publisher
does not signal an error, even if the represented stream is empty; - no items if the wrapped
Publisher
signals an error.
- exactly one item, if the wrapped
Value Members
- object GridFSBucket extends Serializable
A factory for GridFSBucket instances.
A factory for GridFSBucket instances.
- Since
1.2
This is the documentation for the MongoDB Scala driver.
Driver structure
The mongodb scala driver.
To get started you need a MongoClient instance, either from a connection string or via a org.mongodb.scala.MongoClientSettings.
Notable packages include: