07d13c9c
 isisadmin
polymer catalog
|
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
var concat = require('concat-stream');
var reduce = require('through2-reduce');
var asyncMap = require('through2-asyncmap');
var filter = require('through2-filter');
var map = require('through2-map');
var through = require('through2');
var jsonStream = require('JSONStream');
var isStream = require('is-stream');
var split = require('split');
var writeStreamP = require('writestreamp');
var pumpify = require('pumpify');
var from = require('from2');
var concurrent = require('through2-concurrent');
var eos = require('end-of-stream');
exports.create = through;
exports.split = split;
exports.writeFile = writeStreamP;
exports.from = from;
exports.concurrent = concurrent;
exports.onEnd = eos;
exports.parse = jsonStream.parse.bind(jsonStream);
exports.stringify = jsonStream.stringify.bind(jsonStream);
exports.stringify.obj = jsonStream.stringifyObject = function (options) {
options = options || {};
return through.obj(function (chunk, enc, done) {
done(null, JSON.stringify(chunk, null, options.space));
});
}
exports.validate = isStream;
exports.concat = concat;
exports.compose = pumpify;
exports.reduce = reduce;
reduce.obj = function (fn) {
return reduce.call(null, {objectMode: true}, fn);
}
exports.filter = filter;
exports.map = map;
exports.asyncMap = asyncMap;
// Object mode
exports.obj = {
create: exports.create.obj,
split: exports.split.obj,
writeFile: exports.writeFile,
from: from.obj,
concurrent: exports.concurrent.obj,
onEnd: exports.onEnd,
parse: exports.parse,
stringify: exports.stringify.obj,
validate: exports.validate,
concat: exports.concat,
compose: exports.compose.obj,
reduce: exports.reduce.obj,
filter: exports.filter.obj,
map: exports.map.obj,
asyncMap: exports.asyncMap.obj,
get: function (key) {
return exports.obj.create(function (obj, enc, done) {
done(null, obj[key]);
});
}
};
|
