               StreamName: data.StreamDescription.StreamName
             }, (err, data)=>
               cb(err, data.ShardIterator)
-        ,(err, shardIterators)=>
+        , (err, shardIterators)=>
+
+          console.log 'get shards...'
 
           @shards = shardIterators.map (i)=>
             return new KinesisShard(@kinesis, i)

    @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
