1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
| var binary = require('../');
| var test = require('tap').test;
| var EventEmitter = require('events').EventEmitter;
|
| test('loop scan', function (t) {
| t.plan(8 + 6 + 2);
|
| var em = new EventEmitter;
|
| binary.stream(em)
| .loop(function (end) {
| var vars_ = this.vars;
| this
| .scan('filler', 'BEGINMSG')
| .buffer('cmd', 3)
| .word8('num')
| .tap(function (vars) {
| t.strictEqual(vars, vars_);
| if (vars.num != 0x02 && vars.num != 0x06) {
| t.same(vars.filler.length, 0);
| }
| if (vars.cmd.toString() == 'end') end();
| })
| ;
| })
| .tap(function (vars) {
| t.same(vars.cmd.toString(), 'end');
| t.same(vars.num, 0x08);
| })
| ;
|
| setTimeout(function () {
| em.emit('data', new Buffer(
| 'BEGINMSGcmd\x01'
| + 'GARBAGEDATAXXXX'
| + 'BEGINMSGcmd\x02'
| + 'BEGINMSGcmd\x03'
| ));
| }, 10);
|
| setTimeout(function () {
| em.emit('data', new Buffer(
| 'BEGINMSGcmd\x04'
| + 'BEGINMSGcmd\x05'
| + 'GARBAGEDATAXXXX'
| + 'BEGINMSGcmd\x06'
| ));
| em.emit('data', new Buffer('BEGINMSGcmd\x07'));
| }, 20);
|
| setTimeout(function () {
| em.emit('data', new Buffer('BEGINMSGend\x08'));
| }, 30);
| });
|
|
