commit b5d6662b662eb3ca777bd67f3ace6bfdc4eac043 Author: Brian Sakal Date: Wed Apr 26 00:48:50 2023 -0400 initial commit; reads 20 rows diff --git a/.vscode/settings.json b/.vscode/settings.json new file mode 100644 index 0000000..eed8edf --- /dev/null +++ b/.vscode/settings.json @@ -0,0 +1,4 @@ +{ + "deno.enable": true, + "deno.unstable": true +} \ No newline at end of file diff --git a/index.ts b/index.ts new file mode 100644 index 0000000..96e1b4e --- /dev/null +++ b/index.ts @@ -0,0 +1,16 @@ +import { open } from 'npm:lmdb'; +import { CsvParseStream } from 'https://deno.land/std@0.184.0/csv/mod.ts'; + +const fileStream = (await Deno.open('/home/brian/Downloads/options-data/2013-01-02options.cvs', {read: true})).readable; +const csvParseStream = new CsvParseStream({skipFirstRow: true}); + +const rowStream = fileStream + .pipeThrough(new TextDecoderStream()) + .pipeThrough(csvParseStream) +; +const rowReader = rowStream.getReader(); + + +for(let i = 0; i<20; i++){ + console.log(await rowReader.read()); +} \ No newline at end of file