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

		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 initiatePut
			else
				console.log "KinesisProducer : Waiting for stream [#{stream}]"
				wordProducer.waitForStream stream, initiatePut
		return
else
	console.error """
