package main

import "net"

type User struct {
	Name string
	Addr string
	C    chan string
	conn net.Conn
}

func NewUser(conn net.Conn) *User {

	userAddr := conn.RemoteAddr().String()

	user := &User{
		Name: userAddr,
		Addr: userAddr,
		C:    make(chan string),
		conn: conn,
	}

	go user.ListenMessage()

	return user
}

// 监听当前的channel中是否有数据，死循环，有数据就直接输出到客户端
func (u *User) ListenMessage() {
	for {
		msg := <-u.C
		_, _ = u.conn.Write([]byte(msg + "\n"))
	}
}