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

Commit cee7e9c

Browse files
committed
fix: more pubsub tests fixes
1 parent 45f2bad commit cee7e9c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/pubsub/subscribe.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ module.exports = (createCommon, options) => {
7979
expect(msg.data.toString()).to.equal('hi')
8080
expect(msg).to.have.property('seqno')
8181
expect(Buffer.isBuffer(msg.seqno)).to.eql(true)
82-
expect(msg).to.have.property('topicIDs').eql([topic])
82+
expect(msg.topicIDs[0]).to.eq(topic)
8383
expect(msg).to.have.property('from', ipfs1.peerId.id)
8484

8585
ipfs1.pubsub.unsubscribe(topic, handler, (err) => {
@@ -107,7 +107,7 @@ module.exports = (createCommon, options) => {
107107
expect(msg.data.toString()).to.equal('hi')
108108
expect(msg).to.have.property('seqno')
109109
expect(Buffer.isBuffer(msg.seqno)).to.eql(true)
110-
expect(msg).to.have.property('topicIDs').eql([topic])
110+
expect(msg.topicIDs[0]).to.eq(topic)
111111
expect(msg).to.have.property('from', ipfs1.peerId.id)
112112

113113
ipfs1.pubsub.unsubscribe(topic, handler, (err) => {
@@ -135,7 +135,7 @@ module.exports = (createCommon, options) => {
135135
expect(msg.data.toString()).to.equal('hi')
136136
expect(msg).to.have.property('seqno')
137137
expect(Buffer.isBuffer(msg.seqno)).to.eql(true)
138-
expect(msg).to.have.property('topicIDs').eql([topic])
138+
expect(msg.topicIDs[0]).to.eq(topic)
139139
expect(msg).to.have.property('from', ipfs1.peerId.id)
140140

141141
ipfs1.pubsub.unsubscribe(topic, handler, (err) => {

0 commit comments

Comments
 (0)