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

        self.stream.close()
        self.state = DISCONNECTED
        self.on_close.send(self)
Test a send with decimal in json
dataset/ETHPy150Open wtolson/gnsq/gnsq/nsqd.py/Nsqd.close_stream--crossover with--dataset/ETHPy150Open sendwithus/sendwithus_python/sendwithus/test/__init__.py/TestAPI.test_send_decimal