tree cd4fb88cdc599061066048399f5efe31832244d9
parent 4d6c15114b9b6a0fc41b58993cf8acdd0e617b2f
author PowerStateFailure <29687050+PowerStateFailure@users.noreply.github.com> 1617071005 +0500
committer GitHub <noreply@github.com> 1617071005 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJgYoudCRBK7hj4Ov3rIwAAdHIIAERM41BqT613wY46jzJAPdnx
 HrkSC5UhGHRANi2WMl9O0cASl9QAkuw7M/GzUlm29ZwvAiwEZpMyCnZNqeOc112M
 3SMAJKidkgsMVecXQocD0u4tcOOooRHXUrMHaub/T5hXx7GHt/tBiHP7q838IS6m
 QCRXDA2TZfZuW6c0zSXcY+Gs8LBTs7soDOUuQtOyB4tEkapem9hc0MQvqaVEA5dg
 Zqecop2dsJhjmk9Pm0fyrhJbl6PW84aGfjK38AvnMrMDJ+BThO3xG0Z7JSUl0iBo
 3Xtq4W3gCp46+qJ7uMda87bL0Im9uKlRmIm9SuxR149Zu86/9luA7q320vh6gIA=
 =Nyh4
 -----END PGP SIGNATURE-----
 

Fix race condition/goroutine leak in partition discovery goroutine (#474)

* pulsar/consumer_impl: rewrite partition discovery goroutine so that it actually gets closed before close active consumers

* pulsar/producer_impl: rewrite partition discovery goroutine so that it actually gets closed before close active producers

* pulsar/producer_impl: avoid consequtive Close calls side-effects by wrapping method body with sync.Once (similar to consumer.Close)