File tree Expand file tree Collapse file tree 2 files changed +2
-4
lines changed
Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -20,8 +20,8 @@ func ConfigRealtimeRouter(router *gin.RouterGroup) {
2020
2121 // Register Channels
2222 RegisterLiveUpdateRealtimeChannel ()
23- RegisterReactionUpdateRealtimeChannel (daoWrapper )
2423 RegisterLiveRunnerPageUpdateRealtimeChannel (daoWrapper )
24+ RegisterReactionUpdateRealtimeChannel ()
2525 RegisterRealtimeChatChannel ()
2626}
2727
Original file line number Diff line number Diff line change @@ -119,21 +119,19 @@ const (
119119var (
120120 liveReactionListenerMutex sync.RWMutex
121121 liveReactionListener = map [uint ]* liveReactionAdminSessionsWrapper {}
122- daoWrapper dao.DaoWrapper
123122)
124123
125124type liveReactionAdminSessionsWrapper struct {
126125 sessions []* realtime.Context
127126 stream uint
128127}
129128
130- func RegisterReactionUpdateRealtimeChannel (wrapper dao. DaoWrapper ) {
129+ func RegisterReactionUpdateRealtimeChannel () {
131130 RealtimeInstance .RegisterChannel (ReactionUpdateRoomName , realtime.ChannelHandlers {
132131 OnSubscribe : reactionUpdateOnSubscribe ,
133132 OnUnsubscribe : reactionUpdateOnUnsubscribe ,
134133 OnMessage : reactionUpdateSetStream ,
135134 })
136- daoWrapper = wrapper
137135
138136 go func () {
139137 // Notify admins every 5 seconds
You can’t perform that action at this time.
0 commit comments