- var co = require('co');
- var fs = require('fs');
- var fromStream = require('./');
- co(function*(){
- var read = fromStream(fs.createReadStream('index.js'));
- var data;
- while (data = yield read()) console.log(data.toString());
- console.log('all done!');
- })();
|