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.