rmela

/*
 *
 *   Return SQLite3 query results as a Nodejs stream, sensitive to backpressure.
 *
 *   Assumes a foo.db file with a lot of rows - I used 1000 with a number & a string
 */

const stream = require('stream');
const sqlite = require('sqlite3');
class DBStream extends stream.Readable {