diff --git a/Sources/PostgresNIO/New/PostgresChannelHandler.swift b/Sources/PostgresNIO/New/PostgresChannelHandler.swift index cf683949..1f02a768 100644 --- a/Sources/PostgresNIO/New/PostgresChannelHandler.swift +++ b/Sources/PostgresNIO/New/PostgresChannelHandler.swift @@ -370,7 +370,7 @@ final class PostgresChannelHandler: ChannelDuplexHandler { case .sendParseDescribeBindExecuteSync(let query, let promise): self.sendParseDescribeBindExecuteAndSyncMessage(query: query, context: context, promise: promise) case .succeedQuery(let promise, with: let result): - self.succeedQuery(rowsPromise: promise, result: result, context: context) + self.succeedQuery(promise, result: result, context: context) case .failQuery(let promise, with: let error, let cleanupContext): promise.fail(error) if let cleanupContext = cleanupContext { @@ -560,7 +560,7 @@ final class PostgresChannelHandler: ChannelDuplexHandler { } private func succeedQuery( - rowsPromise: EventLoopPromise, + _ promise: EventLoopPromise, result: QueryResult, context: ChannelHandlerContext ) { @@ -582,7 +582,7 @@ final class PostgresChannelHandler: ChannelDuplexHandler { ) } - rowsPromise.succeed(rows) + promise.succeed(rows) } private func closeConnectionAndCleanup(