libtextsecure.js catch-up
FREEBIE
This commit is contained in:
parent
ec70170829
commit
ad8cb870d9
1 changed files with 2 additions and 4 deletions
|
@ -38275,9 +38275,7 @@ MessageReceiver.prototype.extend({
|
||||||
keepalive: { path: '/v1/keepalive', disconnect: true }
|
keepalive: { path: '/v1/keepalive', disconnect: true }
|
||||||
});
|
});
|
||||||
|
|
||||||
this.pending = Promise.resolve();
|
this.pending = this.queueAllCached();
|
||||||
|
|
||||||
this.queueAllCached();
|
|
||||||
},
|
},
|
||||||
close: function() {
|
close: function() {
|
||||||
this.socket.close(3000, 'called close');
|
this.socket.close(3000, 'called close');
|
||||||
|
@ -38398,7 +38396,7 @@ MessageReceiver.prototype.extend({
|
||||||
this.dispatchEvent(ev);
|
this.dispatchEvent(ev);
|
||||||
},
|
},
|
||||||
queueAllCached: function() {
|
queueAllCached: function() {
|
||||||
this.getAllFromCache().then(function(items) {
|
return this.getAllFromCache().then(function(items) {
|
||||||
for (var i = 0, max = items.length; i < max; i += 1) {
|
for (var i = 0, max = items.length; i < max; i += 1) {
|
||||||
this.queueCached(items[i]);
|
this.queueCached(items[i]);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue