1 | 'use strict'
|
2 |
|
3 | var Buffer = require('safe-buffer').Buffer
|
4 | var through = require('through2')
|
5 | var generate = require('mqtt-packet').generate
|
6 | var empty = Buffer.allocUnsafe(0)
|
7 |
|
8 | function generateStream (opts) {
|
9 | var stream = through.obj(process)
|
10 |
|
11 | function process (chunk, enc, cb) {
|
12 | var packet = empty
|
13 |
|
14 | try {
|
15 | packet = generate(chunk, opts)
|
16 | } catch (err) {
|
17 | this.emit('error', err)
|
18 | return
|
19 | }
|
20 |
|
21 | this.push(packet)
|
22 | cb()
|
23 | }
|
24 |
|
25 | return stream
|
26 | }
|
27 |
|
28 | module.exports = generateStream
|