Lines Matching refs:reader
28 """A wrapper for create_connection() returning a (reader, writer) pair.
30 The reader returned is a StreamReader instance; the writer is a
46 reader = StreamReader(limit=limit, loop=loop)
47 protocol = StreamReaderProtocol(reader, loop=loop)
50 writer = StreamWriter(transport, protocol, reader, loop)
51 return reader, writer
80 reader = StreamReader(limit=limit, loop=loop)
81 protocol = StreamReaderProtocol(reader, client_connected_cb,
96 reader = StreamReader(limit=limit, loop=loop)
97 protocol = StreamReaderProtocol(reader, loop=loop)
100 writer = StreamWriter(transport, protocol, reader, loop)
101 return reader, writer
109 reader = StreamReader(limit=limit, loop=loop)
110 protocol = StreamReaderProtocol(reader, client_connected_cb,
201 # Keep a strong reference to the reader until a connection
238 reader = self._stream_reader
239 if reader is not None:
240 reader.set_transport(transport)
244 reader,
246 res = self._client_connected_cb(reader,
253 reader = self._stream_reader
254 if reader is not None:
256 reader.feed_eof()
258 reader.set_exception(exc)
271 reader = self._stream_reader
272 if reader is not None:
273 reader.feed_data(data)
276 reader = self._stream_reader
277 if reader is not None:
278 reader.feed_eof()
311 def __init__(self, transport, protocol, reader, loop):
314 # drain() expects that the reader has an exception() method
315 assert reader is None or isinstance(reader, StreamReader)
316 self._reader = reader
324 info.append(f'reader={self._reader!r}')