co-readable

Easy way to read stream data with co.

Install

1$ npm i co-readable

Usage

readable(stream)

Read a stream data buffer piece by piece.

1const fs = require('fs');
2const readable = require('co-readable');
3const co = require('co');
4
5const read = readable(fs.createReadStream('bigfile'));
6
7co(function* () {
8  let buf;
9  let size = 0;
10  while (buf = yield read(1024)) {
11    console.log('read %d bytes', buf.length);
12    size += buf.length;
13  }
14  console.log('total read %d bytes', size);
15}).catch(function (err) {
16  console.error(err.stack);
17});

readable.readAll(stream)

Read all data into one buffer.

1const fs = require('fs');
2const readable = require('co-readable');
3const co = require('co');
4
5co(function* () {
6  const buf = yield readable.readAll(fs.createReadStream('bigfile'));
7  console.log('total read %d bytes', buf.length);
8}).catch(function (err) {
9  console.error(err.stack);
10});

License

MIT