socketer

type Client interface {
	Write(bytes []byte) error

	MustWrite(bytes []byte)
}

type Config struct {
	ReadLimit  int64
	WriteLimit int64

	ReadBufferSize  int
	WriteBufferSize int
}

type Ws interface {
	Broadcast(bytes []byte)
	Find(id ...string) ([]Client, error)
	FindOne(id string) (Client, error)
	Upgrade(req *http.Request, res http.ResponseWriter, id string) error
	OnRead(fn func(bytes []byte)) Ws

	MustFind(id ...string) []Client
	MustFindOne(id string) Client
	MustUpgrade(req *http.Request, res http.ResponseWriter, id string)
}