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

Commit d6c6aea

Browse files
improve binary data sending
1 parent 4d4fa5a commit d6c6aea

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

src/index.js

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,10 @@ module.exports = class WebSockets {
2424

2525
const url = `ws://${maOpts.host}:${maOpts.port}`
2626
log('dialing %s', url)
27-
const socket = connect(url, cb)
27+
const socket = connect(url, {
28+
binary: true,
29+
onConnect: cb
30+
})
2831
socket.getObservedAddrs = (cb) => {
2932
return cb(null, [ma])
3033
}

test/browser.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,10 @@ describe('libp2p-websockets', () => {
4040
const message = rawMessage.toString('hex')
4141

4242
const s = goodbye({
43-
source: pull.values([message]),
43+
source: pull.values([rawMessage]),
4444
sink: pull.collect((err, results) => {
4545
expect(err).to.not.exist
46-
expect(results).to.be.eql([message])
46+
expect(results).to.be.eql([rawMessage])
4747
done()
4848
})
4949
})
@@ -55,7 +55,7 @@ describe('libp2p-websockets', () => {
5555
source: pull(
5656
pull.infinite(),
5757
pull.take(1000),
58-
pull.map((val) => val.toString())
58+
pull.map((val) => Buffer(val.toString()))
5959
),
6060
sink: pull.collect((err, result) => {
6161
expect(err).to.not.exist

0 commit comments

Comments
 (0)