1
0
forked from dyf/APP
Files
APP/node_modules/mqtt/test/util.js
2025-07-05 14:49:26 +08:00

14 lines
231 B
JavaScript

'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()
})
})
}