diff --git a/batch.go b/batch.go
index 4dff2194..c5b1d32d 100644
--- a/batch.go
+++ b/batch.go
@@ -4,7 +4,6 @@ import (
 	"context"
 
 	"github.com/jackc/pgx/pgconn"
-	"github.com/jackc/pgx/pgproto3"
 	"github.com/jackc/pgx/pgtype"
 	"github.com/pkg/errors"
 )
@@ -198,25 +197,3 @@ func (b *Batch) die(err error) {
 		b.connPool.Release(b.conn)
 	}
 }
-
-func (b *Batch) ensureCommandComplete() error {
-	for b.pendingCommandComplete {
-		msg, err := b.conn.rxMsg()
-		if err != nil {
-			return err
-		}
-
-		switch msg := msg.(type) {
-		case *pgproto3.CommandComplete:
-			b.pendingCommandComplete = false
-			return nil
-		default:
-			err = b.conn.processContextFreeMsg(msg)
-			if err != nil {
-				return err
-			}
-		}
-	}
-
-	return nil
-}