Skip to content

Commit

Permalink
feat(link-addCredits): make addCredits public and promisified
Browse files Browse the repository at this point in the history
  • Loading branch information
mbroadst committed Jun 11, 2015
1 parent 4781f1d commit 4d1899a
Showing 1 changed file with 13 additions and 1 deletion.
14 changes: 13 additions & 1 deletion lib/link.js
Expand Up @@ -140,10 +140,11 @@ Link.prototype._flowReceived = function(flowFrame) {
}
};

Link.prototype._addCredits = function(credits, flowOptions) {
Link.prototype.addCredits = function(credits, flowOptions) {
if (this.role === constants.linkRole.sender) {
throw new exceptions.InvalidStateError('Cannot add link credits as a sender');
}

var opts = flowOptions || {};
this.linkCredit += credits;
this.totalCredits += credits;
Expand All @@ -160,6 +161,17 @@ Link.prototype._addCredits = function(credits, flowOptions) {
var flow = new FlowFrame(opts);
flow.channel = this.session.channel;
this.session.connection.sendFrame(flow);

var self = this;
return new Promise(function(resolve, reject) {
self.once(Link.CreditChange, function() {
resolve();
});

self.once(Link.ErrorReceived, function(error) {
reject(error);
});
});
};

Link.prototype._checkCredit = function() {
Expand Down

0 comments on commit 4d1899a

Please sign in to comment.