Improve smux write

This commit is contained in:
世界
2022-08-12 16:49:25 +08:00
parent 8421a979b4
commit 0a84f60c32
7 changed files with 49 additions and 50 deletions

View File

@@ -146,7 +146,12 @@ func (c *Client) offerNew() (abstractSession, error) {
if err != nil {
return nil, err
}
session, err := c.protocol.newClient(&protocolConn{Conn: conn, protocol: c.protocol})
if vectorisedWriter, isVectorised := bufio.CreateVectorisedWriter(conn); isVectorised {
conn = &vectorisedProtocolConn{protocolConn{Conn: conn, protocol: c.protocol}, vectorisedWriter}
} else {
conn = &protocolConn{Conn: conn, protocol: c.protocol}
}
session, err := c.protocol.newClient(conn)
if err != nil {
return nil, err
}