observable version for walk based on rxjs.

npm install --save walk-observable

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.'),
  })

walk(path, [options])

• share - whether Observable that returned is cold or hot, default is false
• types - listener types, default is only file,it can be names, directory, directories, file, files, end, nodeError, directoryError, errors
• breakOnError - whether Observable emit error when encounter any error, default is true
• autoNext - whether walk process goto next automatically, default is true, if it's false, then you gonna invoke next 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.