rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r446650041
##
File path: pulsar/internal/connection.go
##
@@ -656,20 +662,14 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r431291341
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r429380427
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")