diff options
Diffstat (limited to 'weed/messaging/msgclient')
| -rw-r--r-- | weed/messaging/msgclient/sub_chan.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/sub_chan.go index aae5c0c71..ed25a850c 100644 --- a/weed/messaging/msgclient/sub_chan.go +++ b/weed/messaging/msgclient/sub_chan.go @@ -55,8 +55,8 @@ func (mc *MessagingClient) NewSubChannel(chanName string) (*SubChannel, error) { close(t.ch) return } - t.md5hash.Write(resp.Data.Value) t.ch <- resp.Data.Value + t.md5hash.Write(resp.Data.Value) } }() |