client

type Client[T any] struct {
	Name string
	Addr string
	// TLS FILE
	CertFile string
	// TLS KEY
	KeyFile string
	// TLS
	TLSConfig *tls.Config

	Response *http.Response
	Header   http.Header

	HeartBeatTimeout  time.Duration
	HeartBeatInterval time.Duration
	ReconnectInterval time.Duration
	HeartBeat         func(conn Conn) error

	WriteBufferSize int
	ReadBufferSize  int
	DailTimeout     time.Duration
	SubProtocols    []string

	OnOpen         func(conn Conn)
	OnClose        func(conn Conn)
	OnMessage      func(conn Conn, messageType int, msg []byte)
	OnError        func(stream *socket.Stream[Conn], err error)
	OnException    func(err error)
	OnSuccess      func()
	OnReconnecting func()

	OnUnknown   func(conn Conn, message []byte, next Middle)
	PingHandler func(conn Conn) func(data string) error

	PongHandler func(conn Conn) func(data string) error

	Protocol protocol.Protocol
	// contains filtered or unexported fields
}

type Conn interface {
	Name() string
	SetName(name string)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	Close() error
	Write(messageType int, data []byte) (int, error)
	Read() (int, []byte, error)
	LastPong() time.Time
	SetLastPong(t time.Time)
	Ping() error
	Pong() error
	Conn() *websocket.Conn
	SubProtocols() []string
	SetDeadline(t time.Time) error
	socket.Packer
}

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