const tapLexer = require('tap-lexer')
const through  = require('through2')
 
process.stdin // stream that emits TAP
  .pipe(tapLexer())
  .pipe(though.obj(function (chunk, enc, cb) { // objectMode stream
    // `chunk` is a TAP token object
  }))
 
process.stdin
  .pipe(tapLexer())
  .on('data', token => {})