csv-to-observable 

Transform a CSV stream to an RxJS observable stream. Wrapper around csv-parser

Requirements

- RxJS
- Node 8+

Install

``
$ npm install csv-to-observable
`

Usage

`js
import * as fs from 'fs';
import * as path from 'path'
import csvToObservable from 'csv-to-observable';
import {tap} from 'rxjs/operators'

const stream = fs.createReadStream(path.join(__dirname, 'test.csv'));

csvToObservable(csvStream, { separator: ';' })
.pipe(
tap(item => console.log(item)) // JSON object
)
.subscribe()

`

API

$3

#### stream

Type: ReadableStream

Stream of CSV records. Could be from a file or generated yourself.

#### options

Type: Object`

Same configuration options as defined in csv-parser. To see the default values, check the documentation of csv-parser