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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
// var file = './test/data/multibyte_file.txt';
var file = './test/data/three_line_file.txt';
// var file = './test/data/mac_os_9_file.txt';
// var file = './test/data/separator_file.txt';
var util = require('util');
// var lineReader = require('readline').createInterface({
// input: require('fs').createReadStream(file)
// });
// lineReader.on('line', function (line) {
// console.log('Line from file:', util.inspect(line));
// });
var fs = require('fs');
// var readStream = fs.createReadStream(file);
// // var hash = crypto.createHash('sha1');
// readStream
// .on('readable', function () {
// var chunk;
// while (null !== (chunk = readStream.read())) {
// console.log(chunk.length);
// }
// })
// .on('end', function () {
// console.log('done!');
// });
// var readable = process.stdin;
//
// var readable = fs.createReadStream(file);
// readable.pause();
// console.log(readable.isPaused());
// readable.on('readable', () => {
// var chunk;
// console.log('called');
// while (null !== (chunk = readable.read(4))) {
// console.log('got %d bytes of data: %s', chunk.length, util.inspect(chunk.toString()));
// }
// });
// readable.on('end', () => {
// console.log('done!');
// });
//
//
var lineReader = require('./lib/line_reader');
var readStream = fs.createReadStream('development.log', { start: 0, end: 10000 });
lineReader.eachLine(readStream, (line) => console.log(line));
// var lineReader = require('./lib/line_reader'),
// Promise = require('bluebird');
// var eachLine = Promise.promisify(lineReader.eachLine);
// eachLine(process.stdin, function(line) {
// console.log(line);
// }).then(function() {
// console.log('DONE');
// }).catch(function(err) {
// console.error(err);
// });
// const readline = require('readline');
// const rl = readline.createInterface({
// input: process.stdin,
// output: process.stdout
// });
// rl.question('What do you think of Node.js? ', (answer) => {
// TODO: Log the answer in a database
// console.log('Thank you for your valuable feedback:', answer);
// rl.close();
// });
|
