var fstream = require('finance-stream');
var _ = require('highland');

// build an ongoing ticker which fetches
// yahoo and google stock data in an interval
// of 1 sec
fstream
  .stockTicker(['YHOO', 'GOOG'], ['symbol', 'Ask', 'Bid'])
  .through(fstream.toFloat('Ask', 'Bid'))
  .each(_.log);

// convert euro into baht and
// pipe the response to stdout
fstream
  .exchangeStream('EURTHB')
  .pluck('Rate')
  .pipe(process.stdout);