UnSubscribeEvent is a un-subscription operation
(peersFeed ...interface{})
| 536 | |
| 537 | // UnSubscribeEvent is a un-subscription operation |
| 538 | func (n *server) UnSubscribeMsg(peersFeed ...interface{}) { |
| 539 | for _, m := range peersFeed { |
| 540 | select { |
| 541 | case <-n.ctx.Done(): |
| 542 | case n.unscribeMsg <- reflect.TypeOf(m).String(): |
| 543 | } |
| 544 | } |
| 545 | return |
| 546 | } |
| 547 | |
| 548 | func (n *server) Join(bootstrapIP []string) (num int, err error) { |
| 549 | select { |