pull-ws-bug

pull-ws-bug.js

const connect = require('pull-ws/client')
const pull = require('pull-stream')

const {source} = connect('ws://localhost:1337', (err, stream) => {
  pull(
    stream,
    pull.log()
  )
  // expected: log 'hello!'
  // actual: stream is undefined
})

// pull(
//   source,
//   pull.log()
// )

server.js

const createServer = require('pull-ws/server')
const pull = require('pull-stream')

createServer(stream => {
  pull(
    pull.once('hello!'),
    stream
  )
}).listen(1337)