def close_stream(self):
        if not self.is_connected:
            return

        self.stream.close()
        self.state = DISCONNECTED
        self.on_close.send(self)
Close the underlying socket.
dataset/ETHPy150Open wtolson/gnsq/gnsq/nsqd.py/Nsqd.close_stream