Method BroadcastToSubscribers

http/websocket/websocket/server.go:417–446

(contractAddrs map[string]bool, sub int, resp map[string]interface{})

	}
}
func (self *WsServer) BroadcastToSubscribers(contractAddrs map[string]bool, sub int, resp map[string]interface{}) {
	// broadcast SubscribeMap
	self.Lock()
	defer self.Unlock()
	data := marshalResp(resp)
	for sid, v := range self.SubscribeMap {
		s := self.SessionList.GetSessionById(sid)
		if s == nil {
			continue
		}
		if sub == WSTOPIC_JSON_BLOCK && v.SubscribeJsonBlock {
			s.Send(data)
		} else if sub == WSTOPIC_RAW_BLOCK && v.SubscribeRawBlock {
			s.Send(data)
		} else if sub == WSTOPIC_TXHASHS && v.SubscribeBlockTxHashs {
			s.Send(data)
		} else if sub == WSTOPIC_EVENT && v.SubscribeEvent {
			if len(v.ContractsFilter) == 0 {
				s.Send(data)
				continue
			}
			for _, addr := range v.ContractsFilter {
				if contractAddrs[addr] {
					s.Send(data)
					break
				}
			}
		}
	}
}

func (self *WsServer) initTlsListen() (net.Listener, error) {