Trying to get streams to work

streams.js

var through = require('through2')
var pumpify = require('pumpify')
var request = require('request')

var getProjects = function (cb) {
  var stream = pumpify.obj(
    ex(),
    sendRequest() // Returns a JSON object
  )
  return stream
  // if (cb) { stream.pipe(concat(cb)) } else { return stream }
}

function ex (variable) {
  var stream = through.obj(transform)
  return stream

  function transform (obj, enc, next) {
    this.push(obj)
    next()
  }
}

// SendRequest
// - Internal function used to request a URL in a STREAM friendly manner
function sendRequest () {
  var stream = through.obj(transform)
  return stream

  function transform (query, enc, next) {
    console.log(query)
    var self = this
    self.push('hey' + '\n')
    next()
  }
}

var pipeline = getProjects()
pipeline.write('hello')
pipeline.pipe(process.stdout)