Searched refs:channels (Results 1 – 3 of 3) sorted by relevance
2 proc __consume_subscribe_messages {client type channels} {19 set channels [lreplace $channels $idx $idx]26 assert {[llength $channels] == 0}30 proc subscribe {client channels} {31 $client subscribe {*}$channels35 proc unsubscribe {client {channels {}}} {36 $client unsubscribe {*}$channels40 proc psubscribe {client channels} {41 $client psubscribe {*}$channels45 proc punsubscribe {client {channels {}}} {[all …]
137 ac->sub.channels = dictCreate(&callbackDict,NULL); in redisAsyncInitialize()279 it = dictGetIterator(ac->sub.channels); in __redisAsyncFree()283 dictRelease(ac->sub.channels); in __redisAsyncFree()372 callbacks = ac->sub.channels; in __redisGetSubscribeCallback()604 dictReplace(ac->sub.channels,sname,&cb); in __redisAsyncCommand()
98 struct dict *channels; member