 
         throw err if err
 
+        console.log 'get stream info...'
+
         async.map data.StreamDescription.Shards, (shard, cb)=>
           @kinesis.getShardIterator {
               ShardId: shard.ShardId

              StreamName: data.StreamDescription.StreamName
            }, (err, data)=>
              cb(err, data.ShardIterator)
        ,(err, shardIterators)=>

          @shards = shardIterators.map (i)=>
            return new KinesisShard(@kinesis, i)

    @setup()


module.exports = new KinesisWrapper({})
