gistfile1.js

reader = fn (source) {
  // fetch data from somewhere e.g. http server and emit result
  this.emit('some data')
}

parser = fn (data) {
  // parse and validate data and emit result
  this.emit(parsedData)
}

worker = fn {
  every(10sec, fn {
    reader.read('http://...')
    reader.on('data', parser.parse)
    parser.on('data', println)
  })
}

main = forever worker.work