ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-11-19 03:35:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Request.broadcast. Subscribe to account transaction stream on all connected servers

Browse Source
This commit is contained in:
wltsmrz
2013-10-30 14:09:55 -07:00
parent 60e2aa613a
commit 58bc1b1682
2 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/js/ripple/account.js
View File

@@ -39,7 +39,7 @@ function Account(remote, account) {
if (!self._subs && self._remote._connected) {
self._remote.request_subscribe()
.accounts(self._account_id)
.request();
.broadcast();
}
self._subs += 1;
}
@@ -51,7 +51,7 @@ function Account(remote, account) {
if (!self._subs && self._remote._connected) {
self._remote.request_unsubscribe()
.accounts(self._account_id)
.request();
.broadcast();
}
}
}

23
src/js/ripple/request.js
View File

@@ -27,14 +27,29 @@ function Request(remote, command) {
util.inherits(Request, EventEmitter);
Request.prototype.broadcast = function() {
this._broadcast = true;
return this.request();
};
// Send the request to a remote.
Request.prototype.request = function (remote) {
if (!this.requested) {
this.requested = true;
this.on('error', new Function);
if (this.requested) return;
this.requested = true;
this.on('error', new Function);
this.emit('request', remote);
if (this._broadcast) {
this.remote._servers.forEach(function(server) {
this.set_server(server);
this.remote.request(this);
}, this );
} else {
this.remote.request(this);
this.emit('request', remote);
}
return this;
};
Request.prototype.callback = function(callback, successEvent, errorEvent) {