a $ñ»jQ ã@svddlmZddlZddlmZddlmZGdd„deƒZddd œd d „Z ddd d d dœdd„Z dddœdd„Z dS)é)Ú annotationsNé)Ú T_JSON_DICT)ÚruntimecsBeZdZdZddœdd„Zedddœdd„ƒZ‡fd d „Z‡ZS) Ú StreamHandlez€ This is either obtained from another method or specified as ``blob:`` where ```` is an UUID of a Blob. Ústr)ÚreturncCs|S©N©©Úselfr r ú.E:\soccer\ml_env\Lib\site-packages\mycdp/io.pyÚto_jsonszStreamHandle.to_json)ÚjsonrcCs||ƒSr r )Úclsrr r r Ú from_jsonszStreamHandle.from_jsoncsd tƒ ¡¡S)NzStreamHandle({}))ÚformatÚsuperÚ__repr__r ©Ú __class__r r rszStreamHandle.__repr__) Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚ classmethodrrÚ __classcell__r r rr rs rz0typing.Generator[T_JSON_DICT, T_JSON_DICT, None])Úhandlerccs&tƒ}| ¡|d<d|dœ}|V}dS)zt Close the stream, discard any temporary backing storage. :param handle: Handle of the stream to close. rzIO.close©ÚmethodÚparamsN)Údictr)rr Úcmd_dictrr r r Úcloses  þr#ztyping.Optional[int]zZtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[typing.Optional[bool], str, bool]])rÚoffsetÚsizerccsxtƒ}| ¡|d<|dur"||d<|dur2||d<d|dœ}|V}| dd¡dur^t|dƒndt|dƒt|d ƒfS) aœ Read a chunk of the stream :param handle: Handle of the stream to read. :param offset: *(Optional)* Seek to the specified offset before reading (if not specified, proceed with offset following the last read). Some types of streams may only support sequential reads. :param size: *(Optional)* Maximum number of bytes to read (left upon the agent discretion if not specified). :returns: A tuple with the following items: 0. **base64Encoded** - *(Optional)* Set if the data is base64-encoded 1. **data** - Data that were read. 2. **eof** - Set if the end-of-file condition occurred while reading. rNr$r%zIO.readrZ base64EncodedÚdataÚeof)r!rÚgetÚboolr)rr$r%r r"rr r r Úread-s  þÿ  ùr*zruntime.RemoteObjectIdz/typing.Generator[T_JSON_DICT, T_JSON_DICT, str])Ú object_idrccs.tƒ}| ¡|d<d|dœ}|V}t|dƒS)z© Return UUID of Blob object specified by a remote object id. :param object_id: Object id of a Blob object wrapper. :returns: UUID of the specified Blob. ZobjectIdzIO.resolveBlobrÚuuid)r!rr)r+r r"rr r r Ú resolve_blobYs þr-)NN) Ú __future__rÚtypingÚutilrÚrrrr#r*r-r r r r Ús   ý,