rename Streamer to StreamerConnection

Author: Divjot Arora

x/mongo/driver/driver.go

@@ -65,19 +65,19 @@ type Expirable interface {
 	Alive() bool
 }
 
-// Streamer represents a Connection that supports streaming wire protocol messages using the moreToCome and
+// StreamerConnection represents a Connection that supports streaming wire protocol messages using the moreToCome and
 // exhaustAllowed flags.
 //
 // The SetStreaming and CurrentlyStreaming functions correspond to the moreToCome flag on server responses. If a
 // response has moreToCome set, SetStreaming(true) will be called and CurrentlyStreaming() should return true.
 //
 // CanStream corresponds to the exhaustAllowed flag. The operations layer will set exhaustAllowed on outgoing wire
 // messages to inform the server that the driver supports streaming.
-type Streamer interface {
+type StreamerConnection interface {
 	Connection
 	SetStreaming(bool)
 	CurrentlyStreaming() bool
-	CanStream() bool
+	SupportsStreaming() bool
 }
 
 // Compressor is an interface used to compress wire messages. If a Connection supports compression

x/mongo/driver/operation.go

@@ -613,7 +613,7 @@ func (op Operation) readWireMessage(ctx context.Context, conn Connection, wm []b
 
 	// If the server replied with moreToCome set, the connection should be marked as "streaming".
 	if wiremessage.IsMsgMoreToCome(wm) {
-		if streamer, ok := conn.(Streamer); ok {
+		if streamer, ok := conn.(StreamerConnection); ok {
 			streamer.SetStreaming(true)
 		}
 	}
@@ -790,7 +790,7 @@ func (op Operation) createMsgWireMessage(ctx context.Context, dst []byte, desc d
 	}
 	// Set the ExhaustAllowed flag if the connection supports streaming. This will tell the server that it can
 	// respond with the MoreToCome flag and then stream responses over this connection.
-	if streamer, ok := conn.(Streamer); ok && streamer.CanStream() {
+	if streamer, ok := conn.(StreamerConnection); ok && streamer.SupportsStreaming() {
 		flags |= wiremessage.ExhaustAllowed
 	}
 

x/mongo/driver/operation_exhaust.go

@@ -15,7 +15,7 @@ import (
 
 // ExecuteExhaust gets a connection from the provided deployment and reads a response from it. This will error if the
 // connection CurrentlyStreaming function returns false.
-func (op Operation) ExecuteExhaust(ctx context.Context, conn Streamer, scratch []byte) error {
+func (op Operation) ExecuteExhaust(ctx context.Context, conn StreamerConnection, scratch []byte) error {
 	if !conn.CurrentlyStreaming() {
 		return errors.New("exhaust read must be done with a Streamer that is currently streaming")
 	}

x/mongo/driver/operation_test.go

@@ -657,7 +657,7 @@ func (m *mockConnection) Description() description.Server { return m.rDesc }
 func (m *mockConnection) Close() error                    { return m.rCloseErr }
 func (m *mockConnection) ID() string                      { return m.rID }
 func (m *mockConnection) Address() address.Address        { return m.rAddr }
-func (m *mockConnection) CanStream() bool                 { return m.rCanStream }
+func (m *mockConnection) SupportsStreaming() bool         { return m.rCanStream }
 func (m *mockConnection) CurrentlyStreaming() bool        { return m.rStreaming }
 func (m *mockConnection) SetStreaming(streaming bool)     { m.rStreaming = streaming }
 

x/mongo/driver/topology/connection.go

@@ -341,7 +341,7 @@ func (c *connection) bumpIdleDeadline() {
 type initConnection struct{ *connection }
 
 var _ driver.Connection = initConnection{}
-var _ driver.Streamer = initConnection{}
+var _ driver.StreamerConnection = initConnection{}
 
 func (c initConnection) Description() description.Server {
 	if c.connection == nil {
@@ -370,7 +370,7 @@ func (c initConnection) SetStreaming(streaming bool) {
 func (c initConnection) CurrentlyStreaming() bool {
 	return c.currentlyStreaming
 }
-func (c initConnection) CanStream() bool {
+func (c initConnection) SupportsStreaming() bool {
 	return c.canStream
 }