You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							41 lines
						
					
					
						
							1.1 KiB
						
					
					
				
			
		
		
	
	
							41 lines
						
					
					
						
							1.1 KiB
						
					
					
				| var binary = require('../');
 | |
| var test = require('tap').test;
 | |
| var EventEmitter = require('events').EventEmitter;
 | |
| 
 | |
| test('peek', function (t) {
 | |
|     t.plan(4);
 | |
|     var bufs = [
 | |
|         new Buffer([ 6, 1, 6, 1, 6, 9, 0, 0, 0, 97 ]),
 | |
|         new Buffer([ 98, 99 ]),
 | |
|         new Buffer([ 100, 101, 102 ]),
 | |
|     ];
 | |
|     
 | |
|     var stream = new EventEmitter;
 | |
|     var iv = setInterval(function () {
 | |
|         var buf = bufs.shift();
 | |
|         if (buf) stream.emit('data', buf)
 | |
|         else clearInterval(iv)
 | |
|     }, 20);
 | |
|     
 | |
|     binary.stream(stream)
 | |
|         .buffer('sixone', 5)
 | |
|         .peek(function () {
 | |
|             this.word32le('len');
 | |
|         })
 | |
|         .buffer('buf', 'len')
 | |
|         .word8('x')
 | |
|         .tap(function (vars) {
 | |
|             t.same(
 | |
|                 [].slice.call(vars.sixone),
 | |
|                 [].slice.call(new Buffer([ 6, 1, 6, 1, 6 ]))
 | |
|             );
 | |
|             t.same(vars.buf.length, vars.len);
 | |
|             t.same(
 | |
|                 [].slice.call(vars.buf),
 | |
|                 [ 9, 0, 0, 0, 97, 98, 99, 100, 101 ]
 | |
|             );
 | |
|             t.same(vars.x, 102);
 | |
|         })
 | |
|     ;
 | |
| });
 |