module.exports = (stream, func) => { var remaining = ""; stream.on("data", function (data) { remaining += data; var index = remaining.indexOf("\n"); var last = 0; while (index > -1) { var line = remaining.substring(last, index); last = index + 1; func(line); index = remaining.indexOf("\n", last); } remaining = remaining.substring(last); }); stream.on("error", () => {}); stream.on("end", function () { if (remaining.length > 0) { func(remaining); } }); }; y>
aboutsummaryrefslogtreecommitdiffstats
path: root/db/normalized/user_keys.js
blob: 0d84b74281d5cb604827dfe66c7fb27e0e3f1c6f (plain) (blame) 
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