+
4O|j j R t ^ RIHt ^ RIHtHt ^ RIHtHtH t H
t
H t H t H
t
^ RIHt ^ RIHtHt ! R R]], ]4 t]! . RO4 tR^R ^R
^R ^R ^ R
^@R^/t ! R R4 t]
] ]
]] ]]
]]] ]]3, 3, 3, 3, , ] ]]3, 3, t]
]]3, tR# )z5Constants and types shared across all cursor classes.) annotations)ABCabstractmethod)AnyGenericMappingOptionalSequenceTupleUnion)_CursorAddress)_Address
_DocumentTypec ] tR t^t$ RtR]R& R]R& R]R& R]R& R]R & R
]R & R ]R
& ]R R l4 tR R lt] R R l4 t
] R R l4 t ] R R l4 t R R lt
R R ltR tR # ) _AgnosticCursorBasez
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 V ^8 d QhRR/# ) returnstr )formats "NC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\pymongo/cursor_shared.py __annotate__ _AgnosticCursorBase.__annotate__* s c
R# )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
O99DLL(8::r$ c V ^8 d QhRR/# )r r r r )r s "r! r" r# H s = r$ c
V P # )z5Returns the id of the cursor.
.. versionadded:: 2.2
)r r& s &r! cursor_id _AgnosticCursorBase.cursor_idG s
xxr$ c V ^8 d QhRR/# )r r r r )r s "r! r" r# P s + r$ c
V P # )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 V ^8 d QhRRRR/# )r already_killedr r z$tuple[int, Optional[_CursorAddress]]r )r s "r! r" r# X s
"
"d
"7[
"r$ c R V n V P ' dL V' gD V P pV P f Q h\ V P V P 4 4 pW#3# ^ pRpW#3# )TN)r r r r r( r' r? r8 r< s && r! _prepare_to_die#_AgnosticCursorBase._prepare_to_dieX sf 888N I==, ,,$T]]D4G4G4IJG
!! IG!!r$ c V ^8 d QhRR/# r+ r )r s "r! r" r# d s d r$ c
V P pT P T4 w r#T P P P
P
Y#T P T P 4 T P ' d5 T P P ' d RT P n
RT n RT n R# \ d R# i ; i)z,Closes this cursor without acquiring a lock.NF) r AttributeErrorrB r databaseclient_cleanup_cursor_no_lockr r _implicit_attached_to_cursorrA s & r! r. _AgnosticCursorBase._die_no_lockd s !\\N
" 1 1. A !!((@@
===T]] 4 4 405DMM - DM s B5 5 CC)r r r N)__name__
__module__ __qualname____firstlineno____doc____annotations__r r( r/ propertyr4 r8 r< rB r. __static_attributes__r r$ r! r r s J N
M ; ;*
" r$ r tailable_cursorsecondary_okay oplog_replay
no_timeout
await_dataexhaustpartialc d ] tR t^t^ t ]R, t ]]R, , t ]R, tRt R# )
CursorTyperU rY rZ r N)
rM rN rO rP NON_TAILABLE_QUERY_OPTIONSTAILABLETAILABLE_AWAITEXHAUSTrT r r$ r! r] r] sA L# /0H | <rr s < " # J J J * 3Y '-0# Y | " : qaA""
r
s : U3c5c7383D)D#E EFF
GH'RUWZRZJ[[ c5jr$