 
 
 # Kinesis
-class Kinesis
+class KinesisWrapper
 
   constructor: (options)->
 

    @setup()


module.exports = new Kinesis({})


        throw err if err

        console.log 'get stream info...'

        async.map data.StreamDescription.Shards, (shard, cb)=>
          @kinesis.getShardIterator {
              ShardId: shard.ShardId
