func (c *muxCliConn) Close() error {
	return nil
}
Close does nothing.
package netpollmux
import (
	"context"
	"errors"
	"fmt"
	"net"
	"sync"
	"github.com/cloudwego/netpoll"
	"github.com/cloudwego/kitex/pkg/gofunc"
	"github.com/cloudwego/kitex/pkg/klog"
	"github.com/cloudwego/kitex/pkg/remote"
	np "github.com/cloudwego/kitex/pkg/remote/trans/netpoll"
)
var ErrConnClosed = errors.New("conn closed")
var SharedSize int32 = 32
func newMuxCliConn(connection netpoll.Connection) *muxCliConn {
	c := &muxCliConn{
		muxConn:  newMuxConn(connection),
		seqIDMap: newSharedMap(SharedSize),
	}
	connection.SetOnRequest(c.OnRequest)
	return c
}
type muxCliConn struct {
	muxConn
	seqIDMap *sharedMap  
	logger   klog.FormatLogger
}
func (c *muxCliConn) OnRequest(ctx context.Context, connection netpoll.Connection) (err error) {
	length, seqID, err := parseHeader(connection.Reader())
	if err != nil {
		err = fmt.Errorf("%w: addr(%s)", err, connection.RemoteAddr())
		return c.onError(err, connection)
	}
	asyncCallback, ok := c.seqIDMap.load(seqID)
	if !ok {
		connection.Reader().Skip(length)
		connection.Reader().Release()
		return
	}
	reader, err := connection.Reader().Slice(length)
	if err != nil {
		err = fmt.Errorf("mux read package slice failed: addr(%s), %w", connection.RemoteAddr(), err)
		return c.onError(err, connection)
	}
	gofunc.GoFunc(ctx, func() {
		bufReader := np.NewReaderByteBuffer(reader)
		asyncCallback.Recv(bufReader, nil)
	})
	return nil
}