Create a :class:`MotorCursor`. Same parameters as for PyMongo's :meth:`~pymongo.collection.Collection.find`. Note that ``find`` does

Explicitly kill this cursor on the server. Call like:: await cursor.close()

**DEPRECATED** - Get a document from the most recently fetched batch, or ``None``. See :attr:`fetch_next`. The :meth:`next_object` me

Watch changes on this cluster. Returns a :class:`~MotorChangeStream` cursor which iterates over changes on all databases in this clus

Get an AsyncIOMotorClient. Ignores self.ssl, you must pass 'ssl' argument.

Get a MotorClient. Ignores self.ssl, you must pass 'ssl' argument. You'll probably need to close the client to avoid file-descriptor

Advance the cursor without blocking indefinitely. This method returns the next change document without waiting indefinitely for the n

Retrieve this file's attributes from the server. Returns a Future. .. versionchanged:: 2.0 No longer accepts a callback a

@param async_method: Bound method of a MotorClient, MotorDatabase, etc. @return: A synchronous wrapper around the method

Start a multi-statement transaction. Takes the same arguments as :class:`~pymongo.client_session.TransactionOptions`. Best u

Get the global timeout setting for async tests. Returns a float, the timeout in seconds.

Initial query or getMore. Returns a Future.

Convenience, wait for a new PyMongo MongoClient to connect.

Copied from PyMongo's test.utils.wait_until. Wait up to 10 seconds (by default) for predicate to be true. The predicate must be an awaitable.

Get one element of a set

Write the contents of this file to a :class:`tornado.web.RequestHandler`. This method calls :meth:`~tornado.web.RequestHandler.flush`

A descriptor that wraps a PyMongo method, such as insert_one, and returns an asynchronous version of the method that returns a Future.

Compute the effective hash of a GridOut object for use with an Etag header. Create a FIPS-compliant Etag HTTP header hash using sha256 We use

Split a host:port string into (host, int(port)) pair.

Are we within the with_transaction retry limit?

Wait for snapshot reads to become available to prevent this error: [246:SnapshotUnavailable]: Unable to read from a snapshot due to pending co

Get an open MotorClient for replica set. Ignores self.ssl, you must pass 'ssl' argument.

Return list of command names started.