 		async.whilst truthTest, delay, callback
 		return
 
-
 wordProducer = new KinesisWordProducer
 
 argv = optimist.argv

				process.exit(1)
			else if streamStatus is "ACTIVE"
				console.log "KinesisProducer : stream [#{stream}] is active, initiating put"
				do initiatePuts
			else
				console.log "KinesisProducer : Waiting for stream [#{stream}]"
				wordProducer.waitForStream stream, initiatePuts
		return
else
	console.error """

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