@@ -36,7 +36,7 @@ func (c *ChannelConn) OIDCTokenGenID() uint64 {
3636// (which is always 0)
3737func (c * ChannelConn ) SetOIDCTokenGenID (uint64 ) {}
3838
39- // WriteWireMessage implements the driver.Connection interface.
39+ // Write implements the driver.Connection interface.
4040func (c * ChannelConn ) Write (ctx context.Context , wm []byte ) error {
4141 // Copy wm in case it came from a buffer pool.
4242 b := make ([]byte , len (wm ))
@@ -51,7 +51,7 @@ func (c *ChannelConn) Write(ctx context.Context, wm []byte) error {
5151 return c .WriteErr
5252}
5353
54- // ReadWireMessage implements the driver.Connection interface.
54+ // Read implements the driver.Connection interface.
5555func (c * ChannelConn ) Read (ctx context.Context ) ([]byte , error ) {
5656 var wm []byte
5757 var err error
@@ -133,7 +133,7 @@ func GetCommandFromQueryWireMessage(wm []byte) (bsoncore.Document, error) {
133133 }
134134
135135 var query bsoncore.Document
136- query , wm , ok = wiremessage .ReadQueryQuery (wm )
136+ query , _ , ok = wiremessage .ReadQueryQuery (wm )
137137 if ! ok {
138138 return nil , errors .New ("could not read query" )
139139 }
@@ -157,7 +157,7 @@ func GetCommandFromMsgWireMessage(wm []byte) (bsoncore.Document, error) {
157157 return nil , errors .New ("could not read section type" )
158158 }
159159
160- cmdDoc , wm , ok := wiremessage .ReadMsgSectionSingleDocument (wm )
160+ cmdDoc , _ , ok := wiremessage .ReadMsgSectionSingleDocument (wm )
161161 if ! ok {
162162 return nil , errors .New ("could not read command document" )
163163 }
0 commit comments