Skip to content
This repository was archived by the owner on Mar 17, 2026. It is now read-only.

Commit b2f96ff

Browse files
callmehiphopcallmehiphop
authored
feat: ordered messaging (#716)
1 parent fc5659e commit b2f96ff

17 files changed

Lines changed: 62195 additions & 817 deletions

‎package.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
"presystem-test": "npm run compile",
3232
"system-test": "mocha build/system-test --timeout 600000",
3333
"samples-test": "cd samples/ && npm link ../ && npm test && cd ../",
34-
"test": "c8 mocha build/test",
34+
"test": "c8 mocha build/test/*{,/*}.js",
3535
"lint": "eslint '**/*.js' && gts check",
3636
"predocs": "npm run compile",
3737
"docs": "jsdoc -c .jsdoc.js",

‎samples/system-test/topics.test.js‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,9 +158,10 @@ describe('topics', () => {
158158

159159
const {data, publishTime} = await _pullOneMessage(subscription);
160160
const actualWait = publishTime.getTime() - startTime;
161+
const acceptableLatency = 100;
161162

162163
assert.strictEqual(data.toString(), expectedMessage.data);
163-
assert(actualWait <= waitTime);
164+
assert(actualWait <= waitTime + acceptableLatency);
164165
});
165166

166167
it('should publish with retry settings', async () => {

‎src/publisher.ts‎

Lines changed: 0 additions & 319 deletions
This file was deleted.

0 commit comments

Comments
 (0)