Skip to content

Commit a9d9cf9

Browse files
committed
Added documentation about (*Consumer).Close() behaviour
1 parent 2fcfee8 commit a9d9cf9

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

consumer.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,9 @@ func (c *Consumer) Errors() <-chan error {
3737
return c.errs
3838
}
3939

40-
// Cancel this consumer
40+
// Cancel this consumer.
41+
//
42+
// This will CLOSE Deliveries() channel
4143
func (c *Consumer) Cancel() {
4244
c.m.Lock()
4345
defer c.m.Unlock()

0 commit comments

Comments
 (0)