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
| 'use strict';
|
| var util = require('util');
| var ChunkStream = require('./chunkstream');
| var Filter = require('./filter-parse');
|
|
| var FilterAsync = module.exports = function(bitmapInfo) {
| ChunkStream.call(this);
|
| var buffers = [];
| var that = this;
| this._filter = new Filter(bitmapInfo, {
| read: this.read.bind(this),
| write: function(buffer) {
| buffers.push(buffer);
| },
| complete: function() {
| that.emit('complete', Buffer.concat(buffers));
| }
| });
|
| this._filter.start();
| };
| util.inherits(FilterAsync, ChunkStream);
|
|
