lib/channel.js
function(message) {
      if (message.namespace === data.namespace &&
          message.data.requestId === data.data.requestId) {
        if (timer) {
          clearTimeout(timer);
        }
        self.removeListener('message', answer);
        self.removeListener('disconnect', cancel);
        cb(null, message);
      }
    }
function(message) {
      if (message.namespace === data.namespace &&
          message.data.requestId === data.data.requestId) {
        if (timer) {
          clearTimeout(timer);
        }
        self.removeListener('message', answer);
        self.removeListener('disconnect', cancel);
        cb(null, message);
      }
    }
function ( message ) { if ( message . namespace === data . namespace && message . data . requestId === data . data . requestId ) { if ( timer ) { clearTimeout ( timer ) ; } self . removeListener ( 'message' , answer ) ; self . removeListener ( 'disconnect' , cancel ) ; cb ( null , message ) ; } }
Invoked when we get an answer
Invoked when we get an answer