rm some self variable

Author: jimmywarting

lib/channel_model.js

@@ -15,9 +15,9 @@ class ChannelModel extends EventEmitter {
   constructor(connection) {
     super();
     this.connection = connection;
-    const self = this;
+
     ['error', 'close', 'blocked', 'unblocked'].forEach(ev => {
-      connection.on(ev, self.emit.bind(self, ev));
+      connection.on(ev, this.emit.bind(this, ev));
     });
   }
 
@@ -56,9 +56,8 @@ class Channel extends BaseChannel {
   // response's fields; this is intended to be suitable for implementing
   // API procedures.
   rpc(method, fields, expect) {
-    const self = this;
     return Promise.fromCallback(cb => {
-      return self._rpc(method, fields, expect, cb);
+      return this._rpc(method, fields, expect, cb);
     })
     .then(f => {
       return f.fields;
@@ -75,9 +74,8 @@ class Channel extends BaseChannel {
   }
 
   close() {
-    const self = this;
     return Promise.fromCallback(cb => {
-      return self.closeBecause("Goodbye", defs.constants.REPLY_SUCCESS,
+      return this.closeBecause("Goodbye", defs.constants.REPLY_SUCCESS,
                       cb);
     });
   }
@@ -165,37 +163,34 @@ class Channel extends BaseChannel {
   }
 
   consume(queue, callback, options) {
-    const self = this;
     // NB we want the callback to be run synchronously, so that we've
     // registered the consumerTag before any messages can arrive.
     const fields = Args.consume(queue, options);
     return Promise.fromCallback(cb => {
-      self._rpc(defs.BasicConsume, fields, defs.BasicConsumeOk, cb);
+      this._rpc(defs.BasicConsume, fields, defs.BasicConsumeOk, cb);
     })
     .then(ok => {
-      self.registerConsumer(ok.fields.consumerTag, callback);
+      this.registerConsumer(ok.fields.consumerTag, callback);
       return ok.fields;
     });
   }
 
   cancel(consumerTag) {
-    const self = this;
     return Promise.fromCallback(cb => {
-      self._rpc(defs.BasicCancel, Args.cancel(consumerTag),
+      this._rpc(defs.BasicCancel, Args.cancel(consumerTag),
             defs.BasicCancelOk,
             cb);
     })
     .then(ok => {
-      self.unregisterConsumer(consumerTag);
+      this.unregisterConsumer(consumerTag);
       return ok.fields;
     });
   }
 
   get(queue, options) {
-    const self = this;
     const fields = Args.get(queue, options);
     return Promise.fromCallback(cb => {
-      return self.sendOrEnqueue(defs.BasicGet, fields, cb);
+      return this.sendOrEnqueue(defs.BasicGet, fields, cb);
     })
     .then(f => {
       if (f.id === defs.BasicGetEmpty) {
@@ -204,7 +199,7 @@ class Channel extends BaseChannel {
       else if (f.id === defs.BasicGetOk) {
         const fields = f.fields;
         return new Promise(resolve => {
-          self.handleMessage = acceptMessage(m => {
+          this.handleMessage = acceptMessage(m => {
             m.fields = fields;
             resolve(m);
           });