i S r SSKJr SSKJrJr SSKJrJrJ r J
r
J r J r J
r
SSKJr SSKJrJr " S S\\ \5 r\" / S Q5 rS
S S S
SSSS.r " S S5 r\
\ \
\\ \\
\\\ \\4 4 4 4 \ \\4 4 r\
\\4 rg)z5Constants and types shared across all cursor classes. ) annotations)ABCabstractmethod)AnyGenericMappingOptionalSequenceTupleUnion)_CursorAddress)_Address
_DocumentTypec \ rS rSr% SrS\S' S\S' S\S' S\S ' S\S
' S \S ' S
\S' \SS j5 rSS jr\ SS j5 r
\ SS j5 r \ S S j5 r S S jr
SS jrSrg) _AgnosticCursorBase z
Shared IO-agnostic cursor base used by both async and sync cursor classes.
All IO-specific behavior is implemented in subclasses.
r _collection
Optional[int]_id_dataOptional[_Address]_address _sock_mgrz
Optional[Any]_sessionbool_killedc g)z`_
since they will stop iterating even though they *may* return more
results in the future.
With regular cursors, simply use an asynchronous for loop instead of :attr:`alive`::
async for doc in collection.find():
print(doc)
.. note:: Even if :attr:`alive` is True, :meth:`next` can raise
:exc:`StopIteration`. :attr:`alive` can also be True while iterating
a cursor from a failed server. In this case :attr:`alive` will
return False after :meth:`next` fails to retrieve the next batch
of results from the server.
)r lenr r r s r! alive_AgnosticCursorBase.alive1 s# ( C
O9DLL(8::r$ c U R $ )z5Returns the id of the cursor.
.. versionadded:: 2.2
)r r s r! cursor_id _AgnosticCursorBase.cursor_idG s
xxr$ c U R $ )zbThe (host, port) of the server used, or None.
.. versionchanged:: 3.0
Renamed from "conn_id".
)r r s r! address_AgnosticCursorBase.addressO s }} r$ c SU l U R ( aI U( dB U R nU R c e[ U R U R 5 5 nX#4$ SnS nX#4$ )NTr )r r r r
r" r already_killedr. r1 s r! _prepare_to_die#_AgnosticCursorBase._prepare_to_dieX sd 88N I==, ,,$T]]D4G4G4IJG
!! IG!!r$ c U R nU R U5 u p#U R R R
R
X#U R U R 5 U R ( a3 U R R ( a SU R l
SU l SU l g! [ a gf = f)z,Closes this cursor without acquiring a lock.NF) r AttributeErrorr6 r databaseclient_cleanup_cursor_no_lockr r _implicit_attached_to_cursorr4 s r! r& _AgnosticCursorBase._die_no_lockd s !\\N
" 1 1. A !!((@@
==T]] 4 405DMM - DM s B2 2
B?>B?)r r r N)returnstr)r@ None)r@ r )r@ r )r@ r )r5 r r@ z$tuple[int, Optional[_CursorAddress]])__name__
__module__ __qualname____firstlineno____doc____annotations__r r" r' propertyr+ r. r1 r6 r& __static_attributes__r r$ r! r r s J N
M ; ;*
" r$ r )+ io iC ` @ )tailable_cursorsecondary_okay oplog_replay
no_timeout
await_dataexhaustpartialc B \ rS rSrSr \S r \\S - r \S rSr g)
CursorType r rW r[ r\ r N)
rC rD rE rF NON_TAILABLE_QUERY_OPTIONSTAILABLETAILABLE_AWAITEXHAUSTrJ r r$ r! r_ r_ sA L# /0H | <rp s < " # J J J * 3Y '-0# Y | " : : U3c5c7383D)D#E EFF
GH'RUWZRZJ[[ c5jr$