Searched refs:stream_reader (Results 1 – 3 of 3) sorted by relevance
195 def __init__(self, stream_reader, client_connected_cb=None, loop=None): argument197 if stream_reader is not None:198 self._stream_reader_wr = weakref.ref(stream_reader)199 self._source_traceback = stream_reader._source_traceback206 self._strong_reader = stream_reader
122 stream_reader = asyncio.StreamReader(loop=self.loop)123 protocol = asyncio.StreamReaderProtocol(stream_reader,129 clients.append((stream_reader, trans))
207 4-element tuple: ``(encode_func, decode_func, stream_reader, stream_writer)``.219 * *stream_reader* is a class that supports decoding input from a stream.220 *stream_reader(file_obj)* returns an object that supports the :meth:`read`,