ndjson-to-observable

Transform a NDJSON stream to an RxJS observable stream.

Requirements

• RxJS
• Node 8+

Install

$ npm install ndjson-to-observable

Usage

import * as fs from 'fs';
import * as path from 'path'
import {ndjsonToObservable} from 'ndjson-to-observable';
import {tap} from 'rxjs/operators'
 
const stream = fs.createReadStream(path.join(__dirname, 'test.json'));
 
ndjsonToObservable(stream)
    .pipe(
        tap(item => console.log(item)) // JSON object
    )
    .subscribe()
 

API

ndjsonToObservable(stream)

stream

Type: ReadableStream

Stream of NDJSON records. Could be from a file or generated ad hoc.