 	if words.indexOf(',')
 		words = words.split(',')
 	wordProducer.getStreamStatus stream, (err, status) ->
-		initiatePuts = ->
+		initiatePut = ->
 			if period?
 				wordProducer.putWordsInStreamPeriodically stream, words, period, ->
 			else

				if err?
					console.log "KinesisProducer : Error creating stream [#{stream}]", err
				else
					do initiatePuts
				return
		if status?
			streamStatus = status.StreamDescription.StreamStatus

		async.whilst truthTest, delay, callback
		return

wordProducer = new KinesisWordProducer

argv = optimist.argv
