streamprotoc

type Client struct {
	// contains filtered or unexported fields
}

type Message interface {
	WriteMsg(w *bufio.Writer) error
	ReadMsg(r *bufio.Reader) error
}

type SendMessage struct {
	Inner  Message
	ConnID uint64
	ReqID  uint64
}

type Server struct {
	NewMessage func() *SendMessage
	Handler    func(r *SendMessage, c *ServerConn)
}

type ServerConn struct {
	*Server
	// contains filtered or unexported fields
}