This commit is contained in:
Cloud Wu
2018-08-07 10:49:21 +08:00
parent e55ad63d3c
commit d2ab6863e3

View File

@@ -3,7 +3,7 @@ local mc = require "skynet.multicast.core"
local multicastd
local multicast = {}
local dispatch = setmetatable({} , {__mode = "kv" })
local dispatch = {}
local chan = {}
local chan_meta = {
@@ -70,6 +70,7 @@ function chan:unsubscribe()
local c = assert(self.channel)
skynet.send(multicastd, "lua", "USUB", c)
self.__subscribe = nil
dispatch[c] = nil
end
local function dispatch_subscribe(channel, source, pack, msg, sz)