-
Notifications
You must be signed in to change notification settings - Fork 2
/
index.js
39 lines (33 loc) · 1.55 KB
/
index.js
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
module.exports.pipe = require('pump')
module.exports.merge = require("multi-duplex-stream")
module.exports.condition = require("ternary-stream")
module.exports.each = require('stream-each')
module.exports.filter = require("through2-filter")
module.exports.map = require("through2-map")
module.exports.reduce = require("through2-reduce")
module.exports.spy = require("through2-spy")
module.exports.split = require("split2")
module.exports.pipeline = require('pumpify')
module.exports.duplex = require('duplexify')
module.exports.through = require('through2')
module.exports.concat = require('concat-stream')
module.exports.finished = require('end-of-stream')
module.exports.unique = require("unique-hash-stream")
module.exports.child = require("duplex-child-process")
module.exports.stringify = require("streaming-json-stringify")
module.exports.toJSON = require("stream-to-json")
module.exports.to = require('flush-write-stream')
module.exports.toArray = require("stream-to-array")
module.exports.toString = require("stream-to-string")
module.exports.toPromise = require("stream-to-promise2")
module.exports.toObservable = require("rx-node").fromStream
module.exports.from = require('from2')
module.exports.fromValue = require('stream-from-value')
module.exports.fromPromise = require("stream-from-promise")
module.exports.fromObservable = require("rx-node").writeToStream
var Throttle = require("throttle");
module.exports.throttle = function (n) {
return new Throttle(n);
}
module.exports.Parser = require('stream-parser')
module.exports.balance = require("stream-balance")