fluencelabs/js-libp2p-interfaces
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-interfaces synced 2025-04-02 19:31:25 +00:00
Code Issues Projects Releases Wiki Activity

chore: update aegir and fix lint

Browse Source
This commit is contained in:
David Dias 2017-03-16 15:56:47 +00:00
parent ee7f3ee975
commit b5bdcb84bb
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
package.json
View File

@ -32,18 +32,18 @@
}, },
"homepage": "https://github.com/libp2p/interface-stream-muxer", "homepage": "https://github.com/libp2p/interface-stream-muxer",
"dependencies": { "dependencies": {
"async": "^2.1.4", "async": "^2.1.5",
"chai": "^3.5.0", "chai": "^3.5.0",
"chai-checkmark": "^1.0.1", "chai-checkmark": "^1.0.1",
"detect-node": "^2.0.3", "detect-node": "^2.0.3",
"libp2p-tcp": "~0.9.2", "libp2p-tcp": "~0.9.3",
"multiaddr": "^2.2.1", "multiaddr": "^2.2.2",
"pull-generate": "^2.2.0", "pull-generate": "^2.2.0",
"pull-pair": "^1.1.0", "pull-pair": "^1.1.0",
"pull-stream": "^3.5.0" "pull-stream": "^3.5.0"
}, },
"devDependencies": { "devDependencies": {
"aegir": "^10.0.0" "aegir": "^11.0.0"
}, },
"contributors": [ "contributors": [
"David Dias <daviddias.p@gmail.com>", "David Dias <daviddias.p@gmail.com>",

12
src/spawner.js
View File

@ -22,16 +22,16 @@ module.exports = (muxer, nStreams, nMsg, done, limit) => {
const dialer = muxer.dialer(dialerSocket) const dialer = muxer.dialer(dialerSocket)
listener.on('stream', (stream) => { listener.on('stream', (stream) => {
expect(stream).to.exist expect(stream).to.exist // eslint-disable-line
check() check()
pull( pull(
stream, stream,
pull.through((chunk) => { pull.through((chunk) => {
expect(chunk).to.exist expect(chunk).to.exist // eslint-disable-line
check() check()
}), }),
pull.onEnd((err) => { pull.onEnd((err) => {
expect(err).to.not.exist expect(err).to.not.exist // eslint-disable-line
check() check()
pull(pull.empty(), stream) pull(pull.empty(), stream)
}) })
@ -45,9 +45,9 @@ module.exports = (muxer, nStreams, nMsg, done, limit) => {
const spawnStream = (n, cb) => { const spawnStream = (n, cb) => {
const stream = dialer.newStream((err) => { const stream = dialer.newStream((err) => {
expect(err).to.not.exist expect(err).to.not.exist // eslint-disable-line
check() check()
expect(stream).to.exist expect(stream).to.exist // eslint-disable-line
check() check()
pull( pull(
generate(0, (s, cb) => { generate(0, (s, cb) => {
@ -57,7 +57,7 @@ module.exports = (muxer, nStreams, nMsg, done, limit) => {
}), }),
stream, stream,
pull.collect((err, res) => { pull.collect((err, res) => {
expect(err).to.not.exist expect(err).to.not.exist // eslint-disable-line
check() check()
expect(res).to.be.eql([]) expect(res).to.be.eql([])
check() check()