Skip to content
This repository was archived by the owner on Dec 21, 2021. It is now read-only.

Commit 7a8ed9f

Browse files
committed
test(multipleclients): Fix late sub test.
1 parent 3d7602a commit 7a8ed9f

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

test/integration/MultipleClients.test.js

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -477,13 +477,11 @@ describeRepeats('PubSub with multiple clients', () => {
477477
addAfter(async () => {
478478
await lateSub.unsubscribe()
479479
})
480-
}
480+
}
481481

482-
await publishTestMessages(MAX_MESSAGES, {
482+
published[publisherId] = await publishTestMessages(MAX_MESSAGES, {
483483
waitForLast: true,
484-
async afterEach(pubMsg, req) {
485-
published[publisherId] = published[publisherId] || []
486-
published[publisherId].push(pubMsg)
484+
async afterEach(_pubMsg, req) {
487485
counter += 1
488486
if (counter === 3) {
489487
await waitForStorage(req) // make sure lastest message has hit storage

0 commit comments

Comments
 (0)