const writa = require('writa')

/* first obtain the source stream */
const { createReadStream } = require('fs')
const r = createReadStream('readme.markdown')

/* obtain a writable destination by passing a function to writa */
const s = writa(function (chunk, _, next) {

  /* consume readable's data */
  console.log(chunk+'')

  /* callback moves stream forward to next chunk */
  next()
})

/* pipe to it now from some source stream, like readable */
r.pipe(s)