def _send_message(self, message, callback):
        # logging.debug("_send_message, msg = %r: queue = %r, self.__callback = %r, callback = %r", 
        #               message, self.__job_queue, self.__callback, callback)

        self.__callback = callback
        self.usage_count +=1
        # __request_id used by get_more()
        (self.__request_id, data) = message
        try:
            self.__stream.write(data)
            if self.__callback:
                self.__stream.read(16, callback=self._parse_header)
            else:
                self.__request_id = None
                self.__pool.cache(self)
        
        except __HOLE__:
            self.__alive = False
            raise
        # return self.__request_id
dataset/ETHPy150Open bitly/asyncmongo/asyncmongo/connection.py/Connection._send_message