1.1.0 • Published 6 years ago
walk-observable v1.1.0
walk-observable
observable version for walk based on rxjs.
Installation
npm install --save walk-observable
Getting Started
const path = require('path')
const walk = require('./index')
const { filter } = require('rxjs/operators/filter')
walk('./', { filters: ['node_modules'] })
.pipe(filter(v => v.stat.name.match(/\.json$/)))
.subscribe({
next: v => {
console.log(`type: ${v.type} / ${path.join(v.root, v.stat.name)}`)
},
error: err => console.error(err),
complete: () => console.log('done.'),
})
API
walk(path, options)
Options
share
- whether Observable that returned is cold or hot, default isfalse
types
- listener types, default is onlyfile
,it can benames
,directory
,directories
,file
,files
,end
,nodeError
,directoryError
,errors
breakOnError
- whether Observable emit error when encounter any error, default istrue
autoNext
- whether walk process goto next automatically, default istrue
, if it'sfalse
, then you gonna invokenext
manually.walk('./', { filters: ['node_modules'], autoNext: false }).subscribe(v => { console.log(`type: ${v.type} / ${path.join(v.root, v.stat.name)}`) v.next() })
see walk for more details.