Lines Matching refs:transport
48 transport, _ = await loop.create_connection(
50 writer = StreamWriter(transport, protocol, reader, loop)
98 transport, _ = await loop.create_unix_connection(
100 writer = StreamWriter(transport, protocol, reader, loop)
220 transport = writer.transport
222 self._transport = transport
223 self._over_ssl = transport.get_extra_info('sslcontext') is not None
225 def connection_made(self, transport):
235 transport.abort()
237 self._transport = transport
240 reader.set_transport(transport)
241 self._over_ssl = transport.get_extra_info('sslcontext') is not None
243 self._stream_writer = StreamWriter(transport, self,
307 adds a transport property which references the Transport
311 def __init__(self, transport, protocol, reader, loop):
312 self._transport = transport
322 info = [self.__class__.__name__, f'transport={self._transport!r}']
328 def transport(self):
434 info.append(f'transport={self._transport!r}')
459 def set_transport(self, transport):
461 self._transport = transport
491 # The transport can't be paused.
493 # Forget the transport so we don't keep trying.