Mongo Scala Driver < Back

Packages

package root
This is the documentation for the MongoDB Scala driver.
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:
- MongoClient The MongoClient used to connect and access MongoDB
- MongoDatabase Providing access to a specific database
- MongoCollection Providing access to a specific collection in a database.
Definition Classes
root
package org

Definition Classes
root
package mongodb

Definition Classes
org
package scala
The MongoDB Scala Driver package
The MongoDB Scala Driver package
Contains type aliases and companion objects to help when using the Scala API

Definition Classes
mongodb
Since
1.0
package gridfs

Definition Classes
scala
package helpers
Contains helper classes to create org.mongodb.scala.gridfs.AsyncInputStream or org.mongodb.scala.gridfs.AsyncOutputStream instances from external sources.
Contains helper classes to create org.mongodb.scala.gridfs.AsyncInputStream or org.mongodb.scala.gridfs.AsyncOutputStream instances from external sources.

Definition Classes
gridfs
AsyncInputStream
AsyncOutputStream
GridFSBucket
GridFSDownloadStream
GridFSFindObservable
GridFSUploadStream
JavaAsyncInputStreamToScala
JavaAsyncOutputStreamToScala
ScalaAsyncInputStreamToJava
ScalaAsyncOutputStreamToJava

t

org.mongodb.scala.gridfs

AsyncInputStream

trait AsyncInputStream extends AnyRef

The Async Input Stream interface represents some asynchronous input stream of bytes.

See the org.mongodb.scala.gridfs.helpers package for adapters that create an AsyncInputStream

Since: 1.2

Linear Supertypes

Known Subclasses

GridFSDownloadStream, JavaAsyncInputStreamToScala

Type Hierarchy

Ordering

Alphabetic
By Inheritance

Inherited

AsyncInputStream
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Abstract Value Members

abstract def close(): Observable[Completed]
Closes the input stream
Closes the input stream
returns
a Observable with a single element indicating when the operation has completed
abstract def read(dst: ByteBuffer): Observable[Int]
Reads a sequence of bytes from this stream into the given buffer.
Reads a sequence of bytes from this stream into the given buffer.
dst
the destination buffer
returns
an Observable with a single element indicating total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@native() @throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped