有mqtt

heyujie

2021-05-20 6ebdefb4a5b2be82a8c452c0bb4624f3d85a17b7

1
2
3
4
5
6
7
8
9
10
11
12
13
'use strict'
 
var through = require('through2')
 
module.exports.testStream = function () {
  return through(function (buf, enc, cb) {
    var that = this
    setImmediate(function () {
      that.push(buf)
      cb()
    })
  })
}