Skip to content

Commit

Permalink
Revert "rowsClose: remove unused context parameter"
Browse files Browse the repository at this point in the history
This reverts commit 10c6b86.
  • Loading branch information
fho committed Aug 5, 2021
1 parent 10c6b86 commit 0a7c4e0
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions interceptor.go
Expand Up @@ -22,7 +22,7 @@ type Interceptor interface {

// Rows interceptors
RowsNext(context.Context, driver.Rows, []driver.Value) error
RowsClose(driver.Rows) error
RowsClose(context.Context, driver.Rows) error

// Stmt interceptors
StmtExecContext(context.Context, driver.StmtExecContext, string, []driver.NamedValue) (driver.Result, error)
Expand Down Expand Up @@ -77,7 +77,7 @@ func (NullInterceptor) RowsNext(ctx context.Context, rows driver.Rows, dest []dr
return rows.Next(dest)
}

func (NullInterceptor) RowsClose(rows driver.Rows) error {
func (NullInterceptor) RowsClose(ctx context.Context, rows driver.Rows) error {
return rows.Close()
}

Expand Down
2 changes: 1 addition & 1 deletion rows.go
Expand Up @@ -27,7 +27,7 @@ func (r wrappedRows) Columns() []string {
}

func (r wrappedRows) Close() error {
return r.intr.RowsClose(r.parent)
return r.intr.RowsClose(r.ctx, r.parent)
}

func (r wrappedRows) Next(dest []driver.Value) (err error) {
Expand Down

0 comments on commit 0a7c4e0

Please sign in to comment.