Method Close

protocol/tcp/reply.go:62–71

Close handler

()

// Close handler
func (t *TcpReplyHandler) Close() error {
	fmt.Println("tcp server close")
	t.isClosed.SetBoolAtomic(true)
	t.activeConn.Range(func(key, value interface{}) bool {
		client := key.(*ReplyClient)
		_ = client.Close()
		return true
	})
	return nil
}