MCPcopy
hub / github.com/tornadoweb/tornado / handle_stream

Method handle_stream

tornado/test/tcpclient_test.py:49–51  ·  view source on GitHub ↗
(self, stream, address)

Source from the content-addressed store, hash-verified

47 self.port = sockets[0].getsockname()[1]
48
49 def handle_stream(self, stream, address):
50 self.streams.append(stream)
51 self.queue.put(stream)
52
53 def stop(self):
54 super().stop()

Callers

nothing calls this directly

Calls 2

appendMethod · 0.80
putMethod · 0.45

Tested by

no test coverage detected