const scoot = require('scoot-stream')
const through = require('through2')
const split = require('split2')
 
const so = scoot('hello')
 
const stream = through()
const sp = stream.pipe(split(JSON.parse))
 
sp.on('error', console.log)
 
sp.pipe(through(row, enc, next) => {
  if (row.hello) {
    console.log(row.hello) // world
  }
 
  if (row.foo) {
    console.log(row.foo) // bar
  }
})
 
so(stream, 'world')
so(stream, {
  foo: 'bar'
})