Skip to content
This repository has been archived by the owner on Dec 30, 2023. It is now read-only.

strong-roots-capital/random-record-stream

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

9 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

random-record-stream Build status npm version codecov

Create a Readable stream of random records

Install

npm install @strong-roots-capital/random-record-stream

Use

import randomRecordStream from '@strong-roots-capital/random-record-stream'
import Record from 'timeseries-record'
import moment from 'moment'

let records: Record[] = []
const sink = new Writable({
    objectMode: true,
    write(record: Record, _: any, callback: any) {
        records.push(record)
        callback()
    }
})

const start = moment.utc().startOf('year')
const end = moment.utc().startOf('day')
randomRecordStream(start.toDate(), end.toDate()).pipe(sink)

sink.on('finish', () => {
    console.log('Records streamed:')
    console.log(records)
})

Related