(sessionId string)
| 364 | self.TxHashMap[txhash] = sessionid |
| 365 | } |
| 366 | func (self *WsServer) deleteTxHashes(sessionId string) { |
| 367 | self.Lock() |
| 368 | defer self.Unlock() |
| 369 | for k, v := range self.TxHashMap { |
| 370 | if v == sessionId { |
| 371 | delete(self.TxHashMap, k) |
| 372 | } |
| 373 | } |
| 374 | } |
| 375 | func (self *WsServer) deleteSubscribe(sessionId string) { |
| 376 | self.Lock() |
| 377 | defer self.Unlock() |