import { Flush } from 'minipass-flush'
const f = new Flush<Buffer>({
  flush(cb) {
    // call the cb when done, or return a promise
    // the 'end' event will wait for it, along with
    // close, finish, and prefinish.
    // call the cb with an error, or return a rejecting
    // promise to emit 'error' instead of doing the 'end'
    return rerouteAllEncryptions().then(() => clearAllChannels())
  },
  // all other minipass options accepted as well
})

someDataSource.pipe(f).on('end', () => {
  // proper flushing has been accomplished
})

// Or as a subclass implementing a 'flush' method:
class MyFlush extends Flush {
  flush(cb) {
    // old fashioned callback style!
    rerouteAllEncryptions(er => {
      if (er) return cb(er)
      clearAllChannels(er => {
        if (er) cb(er)
        cb()
      })
    })
  }
}