server

type Conn interface {
	Host() string
	ClientIP() string
	Ping() error
	Pong() error
	SendClose() error
	SendOpen() error
	Close() error
	Write(msg []byte) (int, error)
	WriteToUDP(msg []byte, addr *net.UDPAddr) (int, error)
	FD() int64
	SetFD(fd int64)
	LastPing() time.Time
	SetLastPing(t time.Time)
	CloseChan() chan struct{}
	AcceptChan() chan []byte
	Name() string
	SetName(name string)
	Conn() *net.UDPAddr
	SetDeadline(t time.Time) error
	socket.Packer
}

type Middle router.Middle[*socket.Stream[Conn]]

type Server[T any] struct {
	Name string
	Addr string

	OnClose     func(conn Conn)
	OnMessage   func(conn Conn, msg []byte)
	OnOpen      func(conn Conn)
	OnError     func(stream *socket.Stream[Conn], err error)
	OnSuccess   func()
	OnException func(err error)
	OnUnknown   func(conn Conn, message []byte, next Middle)

	HeartBeatTimeout  time.Duration
	HeartBeatInterval time.Duration
	HandshakeTimeout  time.Duration
	DailTimeout       time.Duration

	Mtu             int
	ReadBufferSize  int // not use yet
	WriteBufferSize int // not use yet

	PingHandler func(conn Conn) func(data string) error
	PongHandler func(conn Conn) func(data string) error
	Protocol    protocol.UDPProtocol
	// contains filtered or unexported fields
}