U ð¤ùdèã@s’dZddlmZddlmZmZmZmZmZm Z m Z erpddl m Z ddl mZmZddlmZddlmZmZGdd „d ƒZGd d „d eƒZd S) z%Represent a response from the server.é)Ú annotations)Ú TYPE_CHECKINGÚAnyÚListÚMappingÚOptionalÚSequenceÚUnion)Ú timedelta)Ú_OpMsgÚ_OpReply)Ú Connection)Ú_AddressÚ _DocumentOutc@s”eZdZdZdddddddœd d „Zedd œd d „ƒZedd œdd„ƒZedd œdd„ƒZedd œdd„ƒZ edd œdd„ƒZ edd œdd„ƒZ dS)ÚResponse©Ú_dataÚ_addressÚ _request_idÚ _durationÚ _from_commandÚ_docsúUnion[_OpMsg, _OpReply]rÚintúOptional[timedelta]ÚboolzSequence[Mapping[str, Any]])ÚdataÚaddressÚ request_idÚdurationÚ from_commandÚdocscCs(||_||_||_||_||_||_dS)alRepresent a response from the server. :Parameters: - `data`: A network response message. - `address`: (host, port) of the source server. - `request_id`: The request id of this operation. - `duration`: The duration of the operation. - `from_command`: if the response is the result of a db command. Nr)Úselfrrrrr r!©r#ú4/tmp/pip-unpacked-wheel-oblwsawz/pymongo/response.pyÚ__init__s zResponse.__init__©ÚreturncCs|jS)z!Server response's raw BSON bytes.)r©r"r#r#r$r8sz Response.datacCs|jS)z"(host, port) of the source server.)rr(r#r#r$r=szResponse.addresscCs|jS)z!The request id of this operation.)rr(r#r#r$rBszResponse.request_idcCs|jS)zThe duration of the operation.)rr(r#r#r$rGszResponse.durationcCs|jS)z.If the response is a result from a db command.)rr(r#r#r$r LszResponse.from_commandcCs|jS)zThe decoded document(s).)rr(r#r#r$r!Qsz Response.docsN) Ú__name__Ú __module__Ú __qualname__Ú __slots__r%Úpropertyrrrrr r!r#r#r#r$rsrc sXeZdZdZddddddddd œ‡fd d „ Zedd œd d„ƒZedd œdd„ƒZ‡ZS)ÚPinnedResponse)Ú_connÚ _more_to_comerrr rrrzList[_DocumentOut])rrÚconnrrr r!Ú more_to_comec s&tƒ ||||||¡||_||_dS)aIRepresent a response to an exhaust cursor's initial query. :Parameters: - `data`: A network response message. - `address`: (host, port) of the source server. - `conn`: The Connection used for the initial query. - `request_id`: The request id of this operation. - `duration`: The duration of the operation. - `from_command`: If the response is the result of a db command. - `docs`: List of documents. - `more_to_come`: Bool indicating whether cursor is ready to be exhausted. N)Úsuperr%r/r0) r"rrr1rrr r!r2©Ú __class__r#r$r%ZszPinnedResponse.__init__r&cCs|jS)zßThe 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. )r/r(r#r#r$r1vszPinnedResponse.conncCs|jS)zIf true, server is ready to send batches on the socket until the result set is exhausted or there is an error. )r0r(r#r#r$r2€szPinnedResponse.more_to_come) r)r*r+r,r%r-r1r2Ú __classcell__r#r#r4r$r.Ws   r.N)Ú__doc__Ú __future__rÚtypingrrrrrrr Údatetimer Zpymongo.messager r Z pymongo.poolr Zpymongo.typingsrrrr.r#r#r#r$Ús $  ;