postgres/cursor

Stream large result sets in batches to limit memory usage

const app = mvfm(prelude, console_, pg);
const prog = app({}, ($) => {
  const query = $.sql`SELECT * FROM users ORDER BY id`;
  return $.sql.cursor(query, 2, (batch) => {
    return $.console.log("batch:", batch);
  });
});
await fold(defaults(app, { postgres: wasmPgInterpreter }), prog);

Initializing database...