яПН !A?hokяПНяПН~яПНdZddlZddlZddlZddlZddlZeedяПНяПНredz ZddlmZddlm Z ddlm Z dd lmZdd lmZddl mZddlmZd ZdedяПНdяПНZdedяПНdяПНZeedяПНяПНrdedяПНdяПНZdedяПНdяПНZGdяПНdejяПНяПНZGdяПНdeejяПНяПНZGdяПНdяПНяПНZGdяПНdяПНяПНZdS))яПНStreamReaderяПНStreamWriterяПНStreamReaderProtocolяПНopen_connectionяПНstart_serverяПНNяПНAF_UNIX)яПНopen_unix_connectionяПНstart_unix_serverяПН)яПН coroutines)яПНevents)яПН exceptions)яПНformat_helpers)яПН protocols)яПНlogger)яПНsleepi)яПНlimitcяПНяПНяПНяПН KяПНtjяПНяПН}t||яПНяПНяПН}t||яПНяПНяПНяПН |jяПН fdяПН||fi|яПНяПНяПНd{VяПНяПН\}}t|яПН ||яПНяПН}||fS)aяПНA wrapper for create_connection() returning a (reader, writer) pair. The reader returned is a StreamReader instance; the writer is a StreamWriter instance. The arguments are all the usual arguments to create_connection() except protocol_factory; most common are positional host and port, with various optional keyword arguments following. Additional optional keyword arguments are loop (to set the event loop instance to use) and limit (to set the buffer limit passed to the StreamReader). (If you want to customize the StreamReader and/or StreamReaderProtocol classes, just copy the code -- there's really nothing special here except some convenience.) яПНrяПНloopяПНrcяПНяПНяПНяПНSяПНNяПНяПНяПНprotocolsяПНяПНz!open_connection..1sяПНяПНяПНяПНяПНN)r яПНget_running_looprrяПНcreate_connectionr) яПНhostяПНportrяПНkwdsrяПНreaderяПН transportяПН_яПНwriterrs @rrrsяПНяПНяПНяПНяПНяПН&яПН"яПН$яПН$яПНDяПН яПНяПНDяПН 1яПН 1яПН 1яПНFяПН#яПНFяПНяПН6яПН6яПН6яПНHяПН/яПНяПН/яПНяПНяПНяПНяПН$яПНяПН.яПН.яПН(,яПН.яПН.яПН.яПН.яПН.яПН.яПН.яПН.яПНLяПНIяПНqяПН яПН)яПНXяПНvяПНtяПН <яПН <яПНFяПНяПН6яПН>яПНrcяПНяПНlяПНяПНяПНKяПНtjяПНяПНяПНяПНяПНяПНfdяПН}яПНj|||fi|яПНяПНяПНd{VяПНяПНS)aяПНStart a socket server, call back for each client connected. The first parameter, `client_connected_cb`, takes two parameters: client_reader, client_writer. client_reader is a StreamReader object, while client_writer is a StreamWriter object. This parameter can either be a plain callback function or a coroutine; if it is a coroutine, it will be automatically converted into a Task. The rest of the arguments are all the usual arguments to loop.create_server() except protocol_factory; most common are positional host and port, with various optional keyword arguments following. The return value is the same as loop.create_server(). Additional optional keyword argument is limit (to set the buffer limit passed to the StreamReader). The return value is the same as loop.create_server(), i.e. a Server object which can be used to stop the service. cяПНNяПНяПНtяПНяПНяПНяПНяПН}t|яПНяПНяПНяПНяПН}|SяПНNrrяПНrrяПНr%rяПНclient_connected_cbrrs яПНяПНяПНrяПНfactoryzstart_server..factoryNs6яПНяПНяПНяПНEяПНяПН5яПН5яПН5яПНяПН'яПНяПН0CяПН-1яПН3яПН3яПН3яПНяПНяПНrN)r r яПН create_server)r.r"r#rr$r/rs` ` @rrr6soяПНяПНяПНяПНяПНяПНяПН,яПН"яПН$яПН$яПНDяПНяПНяПНяПНяПНяПНяПНяПН$яПНяПН#яПНGяПНTяПН4яПН@яПН@яПН4яПН@яПН@яПН@яПН@яПН@яПН@яПН@яПН@яПН@rcяПНяПНяПНяПНKяПНtjяПНяПН}t||яПНяПНяПН}t||яПНяПНяПНяПН|jяПНfdяПН|fi|яПНяПНяПНd{VяПНяПН\}}t|яПН||яПНяПН}||fS)z@Similar to `open_connection` but works with UNIX Domain Sockets.rrcяПНяПНяПНяПНSrrrsяПНrrz&open_unix_connection..bsяПНяПНяПНHяПНrN)r r rrяПНcreate_unix_connectionr) яПНpathrr$rr%r&r'r(rs @rr r ZsяПНяПНяПНяПНяПНяПНяПН&яПН(яПН(яПНяПНяПНEяПНяПН5яПН5яПН5яПНяПН'яПНяПНTяПН:яПН:яПН:яПНяПН8яПНTяПН8яПНяПНяПНяПНяПНdяПН,яПН,яПН&*яПН,яПН,яПН,яПН,яПН,яПН,яПН,яПН,яПНяПН яПН1яПНяПНiяПНяПН6яПН4яПН@яПН@яПНяПНяПНvяПН~яПНrcяПНяПНjяПНяПНяПНKяПНtjяПНяПНяПНяПНяПНяПНfdяПН}яПНj||fi|яПНяПНяПНd{VяПНяПНS)z=Similar to `start_server` but works with UNIX Domain Sockets.cяПНNяПНяПНtяПНяПНяПНяПНяПН}t|яПНяПНяПНяПНяПН}|Sr+r,r-s яПНяПНяПНrr/z"start_unix_server..factoryks6яПНяПНяПН!яПНяПНDяПН9яПН9яПН9яПНFяПН+яПНFяПН4GяПН15яПН7яПН7яПН7яПНHяПНяПНOrN)r r яПНcreate_unix_server)r.r4rr$r/rs` ` @rr r fsmяПНяПНяПНяПНяПНяПНяПНяПН&яПН(яПН(яПНяПН яПН яПН яПН яПН яПН яПН яПН-яПНTяПН,яПНWяПНdяПНCяПНCяПНdяПНCяПНCяПНCяПНCяПНCяПНCяПНCяПНCяПНCrcяПН8яПНeZdZdZd dяПНZdяПНZdяПНZdяПНZdяПНZdяПНZ dS) яПНFlowControlMixina)Reusable flow control logic for StreamWriter.drain(). This implements the protocol methods pause_writing(), resume_writing() and connection_lost(). If the subclass overrides these it must call the super methods. StreamWriter.drain() must wait for _drain_helper() coroutine. NcяПНяПН|яПНtjdяПНяПНяПН|_n||_d|_t jяПНяПН|_d|_dS)NяПН)яПН stacklevelF)r яПН_get_event_loopяПН_loopяПН_pausedяПНcollectionsяПНdequeяПН_drain_waitersяПН_connection_lost)яПНselfrs rяПН__init__zFlowControlMixin.__init__~sKяПНяПНяПН<яПНяПН/яПН1яПН=яПН=яПН=яПНDяПНJяПНJяПНяПНDяПНJяПНяПНяПНяПН)яПН/яПН1яПН1яПНяПНяПН %яПНяПНяПНяПНrcяПНtяПНd|_|jяПНяПНяПНrtjd|яПНяПНdSdS)NTz%r pauses writing)r?r>яПН get_debugrяПНdebugяПНrDs rяПН pause_writingzFlowControlMixin.pause_writingяПНsBяПНяПНяПНяПНяПНяПН:яПНяПНяПН!яПН!яПН 4яПНяПНLяПН,яПНdяПН3яПН3яПН3яПН3яПН3яПН 4яПН 4rcяПНяПНяПНd|_|jяПНяПНяПНrtjd|яПНяПН|jD]+}|яПНяПНяПНs|яПНdяПНяПНяПН,dS)NFz%r resumes writing)r?r>rGrrHrBяПНdoneяПН set_resultяПНrDяПНwaiters rяПНresume_writingzFlowControlMixin.resume_writingяПНssяПНяПНяПНяПНяПНяПН:яПНяПНяПН!яПН!яПН 5яПНяПНLяПН-яПНtяПН4яПН4яПН4яПНяПН)яПН (яПН (яПНFяПНяПН;яПН;яПН=яПН=яПН (яПНяПН!яПН!яПН$яПН'яПН'яПН'яПНяПН (яПН (rcяПНяПНd|_|jsdS|jD]C}|яПНяПНяПНs-|яПН|яПНdяПНяПНяПН.|яПН|яПНяПНяПНDdSяПНNT)rCr?rBrLrMяПН set_exceptionяПНrDяПНexcrOs rяПНconnection_lostz FlowControlMixin.connection_lostяПНsvяПНяПН $яПНяПНяПНяПН|яПН яПНяПНFяПНяПН)яПН .яПН .яПНFяПНяПН;яПН;яПН=яПН=яПН .яПНяПН;яПНяПН%яПН%яПНdяПН+яПН+яПН+яПН+яПНяПН(яПН(яПНяПН-яПН-яПН-яПНяПН .яПН .rcяПНяПН2KяПН|jrtdяПНяПНяПН|jsdS|jяПНяПНяПН}|jяПН|яПНяПН |яПНd{VяПНяПН|jяПН|яПНяПНdS#|jяПН|яПНяПНwxYw)NzConnection lost)rCяПНConnectionResetErrorr?r>яПН create_futurerBяПНappendяПНremoverNs rяПН _drain_helperzFlowControlMixin._drain_helperяПНsяПНяПНяПНяПНяПНяПН яПН :яПН&яПН'8яПН9яПН9яПН9яПНяПН|яПН яПНяПНFяПНяПНяПН)яПН)яПН+яПН+яПНяПНяПНяПН"яПН"яПН6яПН*яПН*яПН*яПН /яПНяПНLяПНLяПНLяПНLяПНLяПНLяПНLяПНяПНяПН&яПН&яПНvяПН.яПН.яПН.яПН.яПН.яПНяПНDяПНяПН&яПН&яПНvяПН.яПН.яПН.яПН.яПНяПНяПНsяПНA:яПН:BcяПНяПНtяПНr)яПНNotImplementedErrorяПНrDяПНstreams rяПН_get_close_waiterz"FlowControlMixin._get_close_waiterяПНsяПНяПН!яПН!rr) яПН__name__яПН __module__яПН__qualname__яПН__doc__rErJrPrVr\rarrrr9r9ts}яПНяПНяПНяПНяПНяПНяПНяПН&яПН&яПН&яПН&яПН4яПН4яПН4яПН(яПН(яПН(яПН.яПН.яПН.яПН /яПН /яПН /яПН"яПН"яПН"яПН"яПН"rr9cяПНlяПНяПНeZdZdZdZdяПНfdяПН ZedяПНяПНяПНZdяПНZdяПНZ яПНfdяПНZ dяПНZd яПНZd яПНZ dяПНZяПНxZS) ra=Helper class to adapt between Protocol and StreamReader. (This is a helper class instead of making StreamReader itself a Protocol subclass, because the StreamReader has other potential uses, and to prevent the user of the StreamReader to accidentally call inappropriate methods of the protocol.) NcяПНLяПНяПНtяПНяПНяПН|яПНяПНяПН|яПН&tj|яПНяПН|_|j|_nd|_|яПН||_d|_d|_d|_ d|_ ||_d|_|j яПНяПНяПН|_dS)NrF)яПНsuperrEяПНweakrefяПНrefяПН_stream_reader_wrяПН_source_tracebackяПН_strong_readerяПН_reject_connectionяПН_stream_writerяПН_taskяПН _transportяПН_client_connected_cbяПН _over_sslr>rYяПН_closed)rDяПН stream_readerr.rяПН __class__s яПНrrEzStreamReaderProtocol.__init__яПНsяПНяПНяПНяПН яПНяПНяПНяПНяПНdяПНяПН#яПН#яПН#яПНяПН$яПН%,яПН[яПНяПН%?яПН%?яПНDяПН"яПН%2яПН%DяПНDяПН"яПН"яПН%)яПНDяПН"яПНяПН*яПН#0яПНDяПНяПН"'яПНяПНяПН"яПНяПНяПНяПНяПН яПНяПНяПНяПН$7яПНяПН!яПНяПНяПНяПНяПНzяПН/яПН/яПН1яПН1яПНяПНяПНяПНrcяПН<яПН|jяПНdS|яПНяПНяПНSr)rkrIs rяПН_stream_readerz#StreamReaderProtocol._stream_readerяПНs"яПНяПНяПН!яПН)яПНяПН4яПНяПН%яПН%яПН'яПН'яПН'rcяПНvяПН|j}|j}||_||_|яПНdяПНяПНdu|_dS)NяПН sslcontext)r>r&rorqяПНget_extra_infors)rDr(rr&s rяПН_replace_writerz$StreamReaderProtocol._replace_writerяПНs>яПНяПНяПНzяПНяПНяПН$яПН яПН$яПНяПНяПН#яПНяПНяПН"яПН1яПН1яПН,яПН?яПН?яПНtяПНKяПНяПНяПНяПНrcяПНXяПНяПНяПНяПНjrEddi}яПНjr яПНj|d<яПНjяПН|яПНяПНяПНяПНяПНяПНdSяПНяПН_яПНj}|яПН|яПНяПНяПНяПНяПНяПНdяПНяПНduяПН_ яПНj яПНяПНtяПНяПН|яПНjяПНяПНяПН_яПНяПН |яПНjяПНяПН}tj|яПНяПНr?яПНяПНfdяПН}яПНjяПН|яПНяПНяПН_яПНjяПН|яПНяПНdяПН_dSdS)NяПНmessagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.яПНsource_tracebackrzcяПНяПНяПНяПН|яПНяПНяПНrяПНяПНяПНяПНdS|яПНяПНяПН}|яПН4яПНjяПНd|яПНdяПНяПНяПНяПНяПНяПНяПНdSdS)Nz*Unhandled exception in client_connected_cb)r~яПН exceptionr&)яПН cancelledяПНcloserяПНr>яПНcall_exception_handler)яПНtaskrUrDr&s яПНяПНrяПНcallbackz6StreamReaderProtocol.connection_made..callbackяПНsяПНяПНяПНяПНяПН~яПН~яПН'яПН'яПНяПН!яПНяПНяПН)яПН)яПН)яПНяПНяПНяПН.яПН.яПН*яПН*яПНCяПНяПНяПНяПН яПН9яПН9яПН'SяПН),яПН)2яПН;яПН;яПНяПНяПНяПН "яПНяПНяПН)яПН)яПН)яПН)яПН)яПН 'яПНr)rnrlr>rяПНяПНabortrqrxяПН set_transportr{rsrrrrorяПНiscoroutineяПНcreate_taskrpяПНadd_done_callbackrm)rDr&яПНcontextr%яПНresrяПНs`` rяПНconnection_madez$StreamReaderProtocol.connection_madeяПНsgяПНяПНяПНяПНяПН"яПН яПНяПН@яПНяПНGяПН яПН%яПН EяПН.2яПН.DяПНяПН*яПН+яПНяПНJяПН-яПН-яПНgяПН6яПН6яПН6яПНяПНOяПНOяПНяПНяПНяПНяПНFяПН#яПНяПНяПНяПН$яПНяПНяПНяПНяПН яПН яПНяПН+яПН+яПН+яПН"яПН1яПН1яПН,яПН?яПН?яПНtяПНKяПНяПНяПНяПН$яПН0яПН".яПНyяПН$яПН/5яПН/3яПНzяПН#;яПН#;яПНDяПНяПНяПН+яПН+яПНFяПН,0яПН,?яПНAяПНAяПНCяПНяПН%яПНcяПН*яПН*яПН 7яПН*яПН*яПН*яПН*яПН*яПН*яПН"яПНZяПН3яПН3яПНCяПН8яПН8яПНяПН яПНяПН яПН,яПН,яПНXяПН6яПН6яПН6яПН"&яПНDяПНяПНяПНяПН/1яПН0rcяПНяПНяПН|j}|яПН,|яПН|яПНяПНяПНn|яПН|яПНяПН|jяПНяПНяПНs7|яПН|jяПНdяПНяПНn|jяПН|яПНяПНt яПНяПНяПН|яПНяПНd|_d|_ d|_ d|_dSr)rxяПНfeed_eofrSrtrLrMrhrVrkrorprq)rDrUr%rvs яПНrrVz$StreamReaderProtocol.connection_lost sяПНяПНяПНяПНяПН$яПНяПНяПНяПНяПН{яПНяПНяПНяПН!яПН!яПН!яПН!яПНяПН$яПН$яПНSяПН)яПН)яПН)яПНяПН|яПН яПН яПН"яПН"яПН 0яПНяПН{яПНяПНяПН'яПН'яПНяПН-яПН-яПН-яПН-яПНяПНяПН*яПН*яПН3яПН/яПН/яПН/яПН яПНяПНяПНяПНяПНяПН$яПН$яПН$яПН!%яПНяПНяПН"яПНяПНяПНяПНяПН яПНяПНяПНяПНяПНrcяПНFяПН|j}|яПН|яПН|яПНяПНdSdSr)rxяПН feed_data)rDяПНdatar%s rяПН data_receivedz"StreamReaderProtocol.data_receiveds2яПНяПНяПН$яПНяПНяПНяПНяПНяПНяПНTяПН"яПН"яПН"яПН"яПН"яПНяПНrcяПНRяПН|j}|яПН|яПНяПНяПН|jrdSdS)NFT)rxrяПНrs)rDr%s rяПНeof_receivedz!StreamReaderProtocol.eof_received!s6яПНяПНяПН$яПНяПНяПНяПНяПНOяПНOяПНяПНяПНяПНяПН>яПН яПНяПН5яПНяПНtrcяПНяПН|jSr)rtr_s rraz&StreamReaderProtocol._get_close_waiter,s яПНяПНяПН|яПНrcяПНяПН |j}|яПНяПНяПНr*|яПНяПНяПНs|яПНяПНяПНdSdSdS#t$rYdSwxYwr)rtrLrяПНrяПНяПНAttributeError)rDяПНcloseds rяПН__del__zStreamReaderProtocol.__del__/sяПНяПНяПН #яПНяПН\яПНFяПНяПН{яПН{яПН}яПН}яПН #яПНVяПН%5яПН%5яПН%7яПН%7яПН #яПНяПН яПН яПН"яПН"яПН"яПН"яПН"яПН #яПН #яПН #яПН #яПНяПНяПН яПН яПН яПНяПНDяПНDяПН яПНяПНяПНsяПНAяПН AяПНAяПНNN)rbrcrdrerlrEяПНpropertyrxr|rяПНrVrяПНrяПНrarяПНяПН __classcell__)rvs@rrrяПНsяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН2яПН2яПН2яПН2яПН2яПН2яПН(яПН(яПН(яПНяПНXяПН(яПН LяПНLяПНLяПН('яПН('яПН('яПНTяПНяПНяПНяПНяПН$#яПН#яПН#яПН яПН яПН яПНяПНяПНяПН #яПН #яПН #яПН #яПН #яПН #яПН #rrcяПНяПНeZdZdZdяПНZdяПНZedяПНяПНяПНZdяПНZdяПНZ dяПНZ dяПНZd яПНZd яПНZ dяПНZdd яПНZdяПНZdddяПНdяПНZdяПНZdS)ra'Wraps a Transport. This exposes write(), writelines(), [can_]write_eof(), get_extra_info() and close(). It adds drain() which returns an optional Future on which you can wait for flow control. It also adds a transport property which references the Transport directly. cяПНяПН||_||_||_||_|jяПНяПНяПН|_|jяПНdяПНяПНdSr)rqяПН _protocolяПН_readerr>rYяПН _complete_futrM)rDr&rr%rs rrEzStreamWriter.__init__EsSяПНяПН#яПНяПНяПН!яПНяПНяПНяПНяПНяПНяПНяПН яПН!яПНZяПН5яПН5яПН7яПН7яПНяПНяПНяПНяПН%яПН%яПНdяПН+яПН+яПН+яПН+яПН+rcяПНяПНяПН|jjd|jяПНяПНg}|jяПН|яПНd|jяПНяПНяПНяПНdяПНdяПН|яПНяПНяПНяПНS)NяПН transport=zreader=яПН<{}>яПН )rvrbrqrяПНrZяПНformatяПНjoinяПНrDяПНinfos rяПН__repr__zStreamWriter.__repr__Os]яПНяПНяПНяПН'яПН)IяПНdяПНoяПН)IяПН)IяПНJяПНяПНяПН<яПН#яПНяПНKяПНKяПН2яПН$яПН,яПН2яПН2яПН3яПН3яПН3яПНяПН}яПН}яПНSяПНXяПНXяПНdяПН^яПН^яПН,яПН,яПН,rcяПНяПН|jSrяПНrqrIs rr&zStreamWriter.transportUs яПНяПНяПНяПНrcяПН:яПН|jяПН|яПНяПНdSr)rqяПНwriteяПНrDrяПНs rrяПНzStreamWriter.writeYsяПНяПНяПНяПНяПНяПНdяПН#яПН#яПН#яПН#яПН#rcяПН:яПН|jяПН|яПНяПНdSr)rqяПН writelinesrяПНs rrяПНzStreamWriter.writelines\sяПНяПНяПНяПН"яПН"яПН4яПН(яПН(яПН(яПН(яПН(rcяПН4яПН|jяПНяПНяПНSr)rqяПН write_eofrIs rrяПНzStreamWriter.write_eof_sяПНяПНяПНяПН(яПН(яПН*яПН*яПН*rcяПН4яПН|jяПНяПНяПНSr)rqяПН can_write_eofrIs rrяПНzStreamWriter.can_write_eofbsяПНяПНяПНяПН,яПН,яПН.яПН.яПН.rcяПН4яПН|jяПНяПНяПНSr)rqrяПНrIs rrяПНzStreamWriter.closeesяПНяПНяПНяПН$яПН$яПН&яПН&яПН&rcяПН4яПН|jяПНяПНяПНSr)rqяПН is_closingrIs rrяПНzStreamWriter.is_closinghsяПНяПНяПНяПН)яПН)яПН+яПН+яПН+rcяПНяПНJKяПН|jяПН|яПНяПНяПНd{VяПНяПНdSr)rяПНrarIs rяПНwait_closedzStreamWriter.wait_closedks4яПНяПНяПНяПНяПНnяПН.яПН.яПНtяПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4rNcяПН8яПН|jяПН||яПНяПНSr)rqr{)rDяПНnameяПНdefaults rr{zStreamWriter.get_extra_infonsяПНяПНяПНяПН-яПН-яПНdяПНGяПН<яПН<яПНяПН start_tlsrqr|)rDrzrяПНrяПНrяПНrяПН new_transports rrяПНzStreamWriter.start_tlsяПНsяПНяПНяПНяПНяПНяПНnяПН9яПНяПНEяПНяПНяПН>яПНяПНяПНjяПНjяПНlяПНlяПНяПНяПНяПНяПНяПНяПНяПН"яПНjяПН2яПН2яПНяПНOяПНXяПНzяПН#яПН_яПН"7яПН3яПН9яПН9яПН9яПН9яПН9яПН9яПН9яПН9яПН яПН(яПНяПНяПНяПН яПН яПНяПН&яПН&яПН&яПН&яПН&rcяПНяПН|jяПНяПНяПНsh|jяПНяПНяПНrt jdtяПНяПНdS|яПНяПНяПНt jd|яПНяПНtяПНяПНdSdS)Nzloop is closedz unclosed )rqrяПНr>яПН is_closedяПНwarningsяПНwarnяПНResourceWarningrяПНrIs rrяПНzStreamWriter.__del__яПНsяПНяПНяПНяПНяПН)яПН)яПН+яПН+яПН EяПНяПНzяПН#яПН#яПН%яПН%яПН EяПНяПН яПН.яПНяПН@яПН@яПН@яПН@яПН@яПНяПН яПН яПНяПНяПНяПНяПН яПН2яПН$яПН2яПН2яПНOяПНDяПНDяПНDяПНDяПНDяПН EяПН Err)rbrcrdrerErяПНrяПНr&rяПНrяПНrяПНrяПНrяПНrяПНrяПНr{rяПНrяПНrяПНrrrrr;sяПНяПНяПНяПНяПНяПНяПНяПН,яПН,яПН,яПН-яПН-яПН-яПНяПНяПНяПНяПНXяПНяПН$яПН$яПН$яПН)яПН)яПН)яПН+яПН+яПН+яПН/яПН/яПН/яПН'яПН'яПН'яПН,яПН,яПН,яПН5яПН5яПН5яПН=яПН=яПН=яПН=яПН-яПН-яПН-яПН4)-яПН.2яПН'яПН'яПН'яПН'яПН'яПНEяПНEяПНEяПНEяПНErrcяПНяПНeZdZdZedfdяПНZdяПНZdяПНZdяПНZdяПНZ dяПНZ dяПНZd яПНZd яПНZ dяПНZdяПНZd яПНZddяПНZddяПНZdяПНZdяПНZdяПНZdS)rNcяПНzяПН|dkrtdяПНяПНяПН||_|яПНtjяПНяПН|_n||_tяПНяПН|_d|_d|_d|_ d|_ d|_|jяПНяПНяПНr-tjtjdяПНяПНяПНяПН|_dSdS)NrzLimit cannot be <= 0Fr)яПН ValueErrorяПН_limitr r=r>яПН bytearrayяПН_bufferяПН_eofяПН_waiterяПН _exceptionrqr?rGrяПН extract_stackяПНsysяПН _getframerl)rDrrs rrEzStreamReader.__init__яПНsяПНяПНяПНяПНAяПН:яПН:яПНяПН3яПН4яПН4яПН4яПНяПНяПНяПНяПН<яПНяПН/яПН1яПН1яПНDяПНJяПНJяПНяПНDяПНJяПН яПН{яПН{яПНяПНяПНяПНяПН яПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН:яПНяПНяПН!яПН!яПН "яПН%3яПН%AяПНяПН яПНaяПН яПН яПН&"яПН&"яПНDяПН"яПН"яПН"яПН "яПН "rcяПН\яПНdg}|jr*|яПНt|jяПНяПНяПНdяПНяПНяПН|jr|яПНdяПНяПН|jt kr|яПНd|jяПНяПНяПНяПН|jr|яПНd|jяПНяПНяПНяПН|jr|яПНd|jяПНяПНяПНяПН|jr|яПНd|jяПНяПНяПНяПН|j r|яПНdяПНяПНd яПН d яПН|яПНяПНяПНяПНS)Nrz bytesяПНeofzlimit=zwaiter=z exception=rяПНяПНpausedrяПНrяПН)rяПНrZяПНlenrяПНrяПНяПН_DEFAULT_LIMITrяПНrяПНrqr?rяПНrяПНrяПНs rrяПНzStreamReader.__repr__яПНs,яПНяПНяПНяПНяПНяПН<яПН 6яПНяПНKяПНKяПН3яПНtяПН|яПН,яПН,яПН4яПН4яПН4яПН5яПН5яПН5яПНяПН9яПН яПНяПНKяПНKяПНяПНяПНяПНяПНяПН;яПН.яПН(яПН(яПНяПНKяПНKяПН.яПНяПНяПН.яПН.яПН/яПН/яПН/яПНяПН<яПН 4яПНяПНKяПНKяПН2яПН$яПН,яПН2яПН2яПН3яПН3яПН3яПНяПН?яПН :яПНяПНKяПНKяПН8яПНTяПН_яПН8яПН8яПН9яПН9яПН9яПНяПН?яПН :яПНяПНKяПНKяПН8яПНTяПН_яПН8яПН8яПН9яПН9яПН9яПНяПН<яПН "яПНяПНKяПНKяПНяПН!яПН!яПН!яПНяПН}яПН}яПНSяПНXяПНXяПНdяПН^яПН^яПН,яПН,яПН,rcяПНяПН|jSr)rяПНrIs rrяПНzStreamReader.exceptionяПНs яПНяПНяПНяПНrcяПНяПН||_|j}|яПН2d|_|яПНяПНяПНs|яПН|яПНяПНdSdSdSr)rяПНrяПНrяПНrSrTs rrSzStreamReader.set_exceptionяПНs]яПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНDяПНLяПНяПН#яПН#яПН%яПН%яПН *яПНяПН$яПН$яПНSяПН)яПН)яПН)яПН)яПН)яПНяПНяПН *яПН *rcяПНяПН|j}|яПН2d|_|яПНяПНяПНs|яПНdяПНяПНdSdSdS)z1Wakeup read*() functions waiting for data or EOF.N)rяПНrяПНrMrNs rяПН_wakeup_waiterzStreamReader._wakeup_waiterяПНsVяПНяПНяПНяПНяПНяПНяПНяПНDяПНLяПНяПН#яПН#яПН%яПН%яПН (яПНяПН!яПН!яПН$яПН'яПН'яПН'яПН'яПН'яПНяПНяПН (яПН (rcяПНяПН||_dSrrяПН)rDr&s rrяПНzStreamReader.set_transportяПНs яПНяПН#яПНяПНяПНяПНrcяПНяПН|jr?t|jяПНяПН|jkr$d|_|jяПНяПНяПНdSdSdS)NF)r?rяПНrяПНrяПНrqяПНresume_readingrIs rяПН_maybe_resume_transportz$StreamReader._maybe_resume_transportяПНsSяПНяПНяПН<яПН -яПНCяПНяПНяПН-яПН-яПНяПНяПН<яПН<яПН яПНDяПНLяПНяПНOяПН*яПН*яПН,яПН,яПН,яПН,яПН,яПН -яПН -яПН<яПНrY)rDяПН func_names rяПН_wait_for_datazStreamReader._wait_for_datasяПНяПНяПНяПНяПНяПН<яПН#яПНяПНяПН5яПН5яПН5яПН6яПН6яПН 6яПНяПН<яПН -яПН яПНDяПНLяПНяПНOяПН*яПН*яПН,яПН,яПН,яПНяПНzяПН/яПН/яПН1яПН1яПНяПНяПН яПНяПН,яПНяПНяПНяПНяПНяПНяПНяПНяПНDяПНLяПНLяПНLяПНяПН4яПНDяПНLяПНяПНяПНяПНsяПН" A8яПН8 BcяПНяПНяПНKяПНd}t|яПНяПН} |яПН|яПНяПНяПНd{VяПНяПН}nяПН#tj$r}|jcYd}~Sd}~wtj$r}|jяПН||jяПНяПНr|jd|j|zяПН=n|jяПН яПНяПН|яПН яПНяПНt|jdяПНяПНяПНd}~wwxYw|S)aяПНRead chunk of data from the stream until newline (b' ') is found. On success, return chunk that ends with newline. If only partial line can be read due to EOF, return incomplete line without terminating newline. When EOF was reached while no bytes read, empty bytes object is returned. If limit is reached, ValueError will be raised. In that case, if newline was found, complete line including newline will be removed from internal buffer. Else, internal buffer will be cleared. Limit is compared against part of the line without newline. If stream was paused, this function will automatically resume it if needed. яПН Nr) rяПНяПН readuntilrяПНIncompleteReadErrorяПНpartialяПНLimitOverrunErrorrяПНяПН startswithяПНconsumedяПНclearrяПНrяПНяПНargs)rDяПНsepяПНseplenяПНlineяПНes rяПНreadlinezStreamReader.readline#sяПНяПНяПНяПН яПНяПНяПНSяПНяПНяПНяПН (яПНяПНяПНяПНяПН,яПН,яПН,яПН,яПН,яПН,яПН,яПН,яПНDяПНDяПНяПНяПН-яПН яПН яПН яПНяПН9яПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН+яПН (яПН (яПН (яПНяПН|яПН&яПН&яПНsяПНAяПНJяПН7яПН7яПН %яПНяПНLяПН!5яПН!яПН*яПНvяПН"5яПН!5яПН6яПН6яПНяПНяПН"яПН"яПН$яПН$яПН$яПНяПН(яПН(яПН*яПН*яПН*яПНяПНQяПНVяПНAяПНYяПН'яПН'яПН'яПНяПНяПНяПНяПН (яПНяПНяПНяПНяПНs(яПН1яПНCяПНAяПНCяПНCяПНA:CяПНCrяПНcяПНяПНяПНKяПНt|яПНяПН}|dkrtdяПНяПНяПН|jяПН|jяПНd} t|jяПНяПН}||z |krJ|jяПН||яПНяПН}|dkrnяПН|dz|z }||jkrt jd|яПНяПНяПН|jrBt|jяПНяПН}|jяПН яПНяПНt j|dяПНяПНяПН|яПНdяПНяПНяПНd{VяПНяПНяПНяПН||jkrt jd |яПНяПНяПН|jd||zяПН}|jd||zяПН=|яПН яПНяПНt|яПНяПНS) aVRead data from the stream until ``separator`` is found. On success, the data and separator will be removed from the internal buffer (consumed). Returned data will include the separator at the end. Configured stream limit is used to check result. Limit sets the maximal length of data that can be returned, not counting the separator. If an EOF occurs and the complete separator is still not found, an IncompleteReadError exception will be raised, and the internal buffer will be reset. The IncompleteReadError.partial attribute may contain the separator partially. If the data cannot be read because of over limit, a LimitOverrunError exception will be raised, and the data will be left in the internal buffer, so it can be read again. rz,Separator should be at least one-byte stringNTяПНяПНяПНяПНяПНrz2Separator is not found, and chunk exceed the limitrяПНz2Separator is found, but chunk is longer than limit)rяПНrяПНrяПНrяПНяПНfindrяПНrrяПНrяПНяПНbytesrяПНrяПНrяПНrяПН)rDяПН separatorrяПНяПНoffsetяПНbuflenяПНisepяПНchunks rrяПНzStreamReader.readuntilBsяПНяПНяПНяПНяПН(яПНYяПНяПНяПНяПНяПНQяПН;яПН;яПНяПНKяПНLяПНLяПНLяПНяПН?яПН&яПНяПН/яПН!яПН*яПНяПН 3яПНяПНяПНяПН&яПН&яПНFяПНяПНяПНяПН&яПН(яПН(яПНяПН|яПН(яПН(яПНяПНFяПН;яПН;яПНяПНяПН2яПН:яПН:яПНяПН яПН!яПНяПНfяПН,яПНяПНяПНDяПНKяПН'яПН'яПН$яПН6яПНLяПНяПН яПН яПН яПНяПНyяПН BяПНяПНdяПНlяПН+яПН+яПНяПНяПНяПН"яПН"яПН$яПН$яПН$яПН яПН4яПНUяПНDяПНAяПНAяПНAяПНяПН%яПН%яПНkяПН2яПН2яПН2яПН2яПН2яПН2яПН2яПН2яПН2яПН= 3яПН@яПН$яПН+яПНяПНяПНяПН.яПНDяПНdяПНLяПНLяПН LяПНяПНяПН^яПНdяПНVяПНmяПН^яПН,яПНяПНяПНLяПНяПН$яПНяПН-яПНяПН(яПНяПН$яПН$яПН&яПН&яПН&яПНяПНUяПН|яПН|яПНrrcяПНяПНKяПН|jяПН|jяПН|dkrdS|dkrQg} |яПН|jяПНяПНяПНd{VяПНяПН}|sn|яПН|яПНяПНяПН9dяПН|яПНяПНS|js"|js|яПНdяПНяПНяПНd{VяПНяПНt|jd|яПНяПНяПН}|jd|яПН=|яПН яПНяПН|S)aяПНRead up to `n` bytes from the stream. If `n` is not provided or set to -1, read until EOF, then return all read bytes. If EOF was received and the internal buffer is empty, return an empty bytes object. If `n` is 0, return an empty bytes object immediately. If `n` is positive, return at most `n` available bytes as soon as at least 1 byte is available in the internal buffer. If EOF is received before any byte is read, return an empty bytes object. Returned value is not limited with limit, configured at stream creation. If stream was paused, this function will automatically resume it if needed. NrrTяПНread) rяПНr rяПНrZrяПНrяПНrяПНrяПНrrяПН)rDяПНnяПНblocksяПНblockrяПНs rr zStreamReader.readяПНsяПНяПНяПНяПН,яПН?яПН&яПНяПН/яПН!яПНяПНяПН6яПН6яПНяПН3яПНяПНqяПН5яПН5яПН яПНFяПН %яПН"яПНiяПНiяПНяПНяПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПНяПНяПНяПНяПНяПН яПН яПНeяПН$яПН$яПН$яПН %яПН яПН8яПН8яПНFяПН#яПН#яПН#яПНяПН|яПН .яПНDяПНIяПН .яПНяПН%яПН%яПНfяПН-яПН-яПН-яПН-яПН-яПН-яПН-яПН-яПН-яПНяПНTяПН\яПН"яПН1яПН"яПН%яПН&яПН&яПНяПНяПНLяПНяПН!яПНяПНяПНяПН$яПН$яПН&яПН&яПН&яПНяПНrcяПНяПНKяПН|dkrtdяПНяПНяПН|jяПН|jяПН|dkrdSt|jяПНяПН|kr||jrBt|jяПНяПН}|jяПНяПНяПНtj||яПНяПНяПН|яПН dяПНяПНяПНd{VяПНяПНt|jяПНяПН|kяПН|t|jяПНяПН|kr.t|jяПНяПН}|jяПНяПНяПНn&t|jd|яПНяПНяПН}|jd|яПН=|яПН яПНяПН|S)aяПНRead exactly `n` bytes. Raise an IncompleteReadError if EOF is reached before `n` bytes can be read. The IncompleteReadError.partial attribute of the exception will contain the partial read bytes. if n is zero, return empty bytes object. Returned value is not limited with limit, configured at stream creation. If stream was paused, this function will automatically resume it if needed. rz*readexactly size can not be less than zeroNrяПНreadexactly)rяПНrяПНrяПНrяПНrяПНrrяПНrrяПНrяПНrяПН)rDrяПН incompleterяПНs rrzStreamReader.readexactlyяПНsKяПНяПНяПНяПН яПНqяПН5яПН5яПНяПНIяПНJяПНJяПНJяПНяПН?яПН&яПНяПН/яПН!яПНяПНяПН6яПН6яПНяПН3яПНяПН$яПН,яПНяПНяПН!яПН#яПН#яПНяПНyяПН DяПН"яПН4яПН<яПН0яПН0яПН яПНяПНяПН"яПН"яПН$яПН$яПН$яПН яПН4яПНZяПНяПНCяПНCяПНCяПНяПН%яПН%яПНmяПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН4яПН яПН$яПН,яПНяПНяПН!яПН#яПН#яПНяПНtяПН|яПНяПНяПНяПН!яПН!яПНяПНяПНяПН&яПН&яПНDяПНяПНLяПНяПНяПН яПН яПН яПН яПНяПНяПНяПНbяПНqяПНbяПН)яПН*яПН*яПНDяПНяПНяПНRяПНaяПНRяПН яПНяПН$яПН$яПН&яПН&яПН&яПНяПНrcяПНяПН|SrrrIs rяПН __aiter__zStreamReader.__aiter__яПНsяПНяПНяПНrcяПНяПНXKяПН|яПНяПНяПНяПНd{VяПНяПН}|dkrtяПН|S)Nr)rяПНяПНStopAsyncIteration)rDяПНvals rяПН __anext__zStreamReader.__anext__яПНs9яПНяПНяПНяПНяПНMяПНMяПНOяПНOяПН#яПН#яПН#яПН#яПН#яПН#яПНяПНяПН#яПН:яПН:яПН$яПН$яПНяПН r)rяПН)r)rbrcrdrlrяПНrErяПНrяПНrSrяПНrяПНrяПНrяПНrяПНrяПНrяПНrяПНrяПНr rrrrrrrrяПНs4яПНяПНяПНяПНяПНяПНяПНяПН+яПН$яПН"яПН"яПН"яПН"яПН,-яПН-яПН-яПН$яПНяПНяПН*яПН*яПН*яПН(яПН(яПН(яПН$яПН$яПН$яПН-яПН-яПН-яПН яПНяПНяПН.яПН.яПН.яПН$яПН$яПН$яПН, яПН яПН яПН8яПНяПНяПН>YяПНYяПНYяПНYяПНv1яПН1яПН1яПН1яПНf'яПН'яПН'яПНRяПНяПНяПНяПНяПНяПНяПНrrrяПНr)яПН__all__r@яПНsocketrяПНrяПНriяПНhasattrяПНrr rrrяПНlogrяПНtasksrrяПНrrr r яПНProtocolr9rrrrrrяПНrsfяПНяПН'яПНяПНяПНяПНяПНяПН яПН яПН яПН яПН яПН яПН яПН яПНяПНяПНяПНяПНяПНяПНяПНяПН яПН7яПН6яПН9яПНяПНяПН=яПНяПН<яПН<яПНGяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН .яПНяПНяПНяПНяПНяПН8AяПН+яПНAяПНAяПНAяПНAяПНAяПНBяПН7яПН6яПН9яПНяПНяПНDяПН яПН)7яПН яПН яПН яПН яПН яПНDяПН&4яПНDяПНDяПНDяПНDяПНDяПН="яПН="яПН="яПН="яПН="яПНyяПН)яПН="яПН="яПН="яПН@D#яПНD#яПНD#яПНD#яПНD#яПН+яПНYяПН-?яПНD#яПНD#яПНD#яПНNcEяПНcEяПНcEяПНcEяПНcEяПНcEяПНcEяПНcEяПНJ`яПН`яПН`яПН`яПН`яПН`яПН`яПН`яПН`яПН`r