luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove unreachable code

Browse source
This commit is contained in:
Harlow Ward 2019-02-18 10:37:38 -08:00
parent 27f13ed3fc
commit db9668152a
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
consumer.go
View file

@ -198,6 +198,7 @@ func (c *Consumer) getShardIDs(streamName string) ([]string, error) {
var listShardsInput = &kinesis.ListShardsInput{ var listShardsInput = &kinesis.ListShardsInput{
StreamName: aws.String(streamName), StreamName: aws.String(streamName),
} }
for { for {
resp, err := c.client.ListShards(listShardsInput) resp, err := c.client.ListShards(listShardsInput)
if err != nil { if err != nil {
@ -216,7 +217,6 @@ func (c *Consumer) getShardIDs(streamName string) ([]string, error) {
NextToken: resp.NextToken, NextToken: resp.NextToken,
} }
} }
return ss, nil
} }
func (c *Consumer) getShardIterator(streamName, shardID, seqNum string) (*string, error) { func (c *Consumer) getShardIterator(streamName, shardID, seqNum string) (*string, error) {