misc/cosmopolite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make message ordering test more comprehensive and fix a message ordering bug.

Browse Source
This commit is contained in:
Ian Gulliver
2014-05-18 22:13:48 +03:00
parent 1ee22da229
commit 640da84124
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
static/cosmopolite.js
View File

@@ -629,7 +629,7 @@ Cosmopolite.prototype.onMessage_ = function(e) {
for (var insertAfter = subscription.messages.length - 1; for (var insertAfter = subscription.messages.length - 1;
insertAfter >= 0; insertAfter--) { insertAfter >= 0; insertAfter--) {
var message = subscription.messages[insertAfter]; var message = subscription.messages[insertAfter];
if (message['id'] < e['message']['id']) { if (message['id'] < e['id']) {
break; break;
} }
} }

2
static/test.js
View File

@@ -332,8 +332,8 @@ asyncTest('Message ordering', function() {
cosmo.sendMessage(subject, messages.shift(), keys.shift()).then(sendNextMessage); cosmo.sendMessage(subject, messages.shift(), keys.shift()).then(sendNextMessage);
} else { } else {
cosmo.subscribe(subject, 1).then(function() { cosmo.subscribe(subject, 1).then(function() {
cosmo.subscribe(subject, 2).then(function() {
cosmo.subscribe(subject, 0, null, ['X']).then(function() { cosmo.subscribe(subject, 0, null, ['X']).then(function() {
cosmo.subscribe(subject, 2).then(function() {
var fetched = cosmo.getMessages(subject); var fetched = cosmo.getMessages(subject);
equal(fetched.length, 3, 'three messages'); equal(fetched.length, 3, 'three messages');
equal(fetched[0]['message'], 'C', 'message 0: C matches'); equal(fetched[0]['message'], 'C', 'message 0: C matches');