diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-05-17 17:38:21 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-05-17 17:38:21 -0700 |
| commit | bff09fb74fbcd49ce13b282ed92919769da56377 (patch) | |
| tree | d3ef64bfa940610694920b655b26be285860e49e /weed/messaging/msgclient/subscriber.go | |
| parent | f5684839a2799656c0d8ddf68e191b2c4e29ed30 (diff) | |
| download | seaweedfs-bff09fb74fbcd49ce13b282ed92919769da56377.tar.xz seaweedfs-bff09fb74fbcd49ce13b282ed92919769da56377.zip | |
fix looping
Diffstat (limited to 'weed/messaging/msgclient/subscriber.go')
| -rw-r--r-- | weed/messaging/msgclient/subscriber.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/messaging/msgclient/subscriber.go b/weed/messaging/msgclient/subscriber.go index 01e63df40..caa795626 100644 --- a/weed/messaging/msgclient/subscriber.go +++ b/weed/messaging/msgclient/subscriber.go @@ -102,10 +102,10 @@ func (s *Subscriber) Subscribe(processFn func(m *messaging_pb.Message)) { for i := 0; i < len(s.subscriberClients); i++ { if s.subscriberClients[i] != nil { wg.Add(1) - go func() { + go func(subscriberClient messaging_pb.SeaweedMessaging_SubscribeClient) { defer wg.Done() - doSubscribe(s.subscriberClients[i], processFn) - }() + doSubscribe(subscriberClient, processFn) + }(s.subscriberClients[i]) } } wg.Wait() |