o 'èhåã@s†dZddlmZddlmZmZmZmZmZm Z er2ddl m Z ddl m Z mZddlmZmZmZGdd„dƒZGd d „d eƒZd S) z%Represent a response from the server.é)Ú annotations)Ú TYPE_CHECKINGÚAnyÚMappingÚOptionalÚSequenceÚUnion)Ú timedelta)Ú_OpMsgÚ_OpReply)Ú_AddressÚ_AgnosticConnectionÚ _DocumentOutc@sneZdZdZddd„Zeddd„ƒZed dd„ƒZed!dd„ƒZed"dd„ƒZ ed#dd„ƒZ ed$dd„ƒZ dS)%ÚResponse©Ú_dataÚ_addressÚ _request_idÚ _durationÚ _from_commandÚ_docsÚdataúUnion[_OpMsg, _OpReply]Úaddressr Ú request_idÚintÚdurationúOptional[timedelta]Ú from_commandÚboolÚdocsúSequence[Mapping[str, Any]]cCs(||_||_||_||_||_||_dS)a\Represent a response from the server. :param data: A network response message. :param address: (host, port) of the source server. :param request_id: The request id of this operation. :param duration: The duration of the operation. :param from_command: if the response is the result of a db command. Nr)Úselfrrrrrr ©r#úL/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/response.pyÚ__init__s  zResponse.__init__ÚreturncCó|jS)z!Server response's raw BSON bytes.)r©r"r#r#r$r6óz Response.datacCr')z"(host, port) of the source server.)rr(r#r#r$r;r)zResponse.addresscCr')z!The request id of this operation.)rr(r#r#r$r@r)zResponse.request_idcCr')zThe duration of the operation.)rr(r#r#r$rEr)zResponse.durationcCr')z.If the response is a result from a db command.)rr(r#r#r$rJr)zResponse.from_commandcCr')zThe decoded document(s).)rr(r#r#r$r Or)z Response.docsN) rrrr rrrrrrr r!)r&r)r&r )r&r)r&r©r&r)r&r!) Ú__name__Ú __module__Ú __qualname__Ú __slots__r%Úpropertyrrrrrr r#r#r#r$rs      rcs>eZdZdZd‡fdd„ Zeddd„ƒZeddd„ƒZ‡ZS)ÚPinnedResponse)Ú_connÚ _more_to_comerrrr Úconnr rrrrrrr úlist[_DocumentOut]Ú more_to_comec s&tƒ ||||||¡||_||_dS)aLRepresent a response to an exhaust cursor's initial query. :param data: A network response message. :param address: (host, port) of the source server. :param conn: The AsyncConnection/Connection used for the initial query. :param request_id: The request id of this operation. :param duration: The duration of the operation. :param from_command: If the response is the result of a db command. :param docs: List of documents. :param more_to_come: Bool indicating whether cursor is ready to be exhausted. N)Úsuperr%r1r2) r"rrr3rrrr r5©Ú __class__r#r$r%Xs zPinnedResponse.__init__r&cCr')zïThe AsyncConnection/Connection used for the initial query. The server will send batches on this socket, without waiting for getMores from the client, until the result set is exhausted or there is an error. )r1r(r#r#r$r3sszPinnedResponse.conncCr')zIf true, server is ready to send batches on the socket until the result set is exhausted or there is an error. )r2r(r#r#r$r5}szPinnedResponse.more_to_come)rrrr r3r rrrrrrr r4r5r)r&r r*) r+r,r-r.r%r/r3r5Ú __classcell__r#r#r7r$r0Us  r0N)Ú__doc__Ú __future__rÚtypingrrrrrrÚdatetimer Úpymongo.messager r Úpymongo.typingsr r rrr0r#r#r#r$Ús   :