From 3e9760ef2f351144d40ea8aaea75dec27c57715c Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Mon, 8 Apr 2019 21:27:08 -0700 Subject: [PATCH] spelling --- broker.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/broker.go b/broker.go index b1207f2..2c9959b 100644 --- a/broker.go +++ b/broker.go @@ -49,8 +49,8 @@ func (b *broker) pollShards(ctx context.Context) { } // leaseShards attempts to find new shards that need to be -// processed; when a new shard is found it passing the shard -// ID back to the consumer on the shard channel +// processed; when a new shard is found it passes the shard +// ID back to the consumer on the shardc channel func (b *broker) leaseShards() { b.shardMu.Lock() defer b.shardMu.Unlock()