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('hello'),
    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) {
    var query = variable
    this.push(query)
  }
}

// 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')
  }
}

getProjects().pipe(process.stdout)