Skip to content

Commit

Permalink
revert no-longer needed change
Browse files Browse the repository at this point in the history
  • Loading branch information
MahdiBM committed Aug 8, 2024
1 parent 4b0c2e7 commit b966180
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions Sources/PostgresNIO/New/PostgresChannelHandler.swift
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down Expand Up @@ -560,7 +560,7 @@ final class PostgresChannelHandler: ChannelDuplexHandler {
}

private func succeedQuery(
rowsPromise: EventLoopPromise<PSQLRowStream>,
_ promise: EventLoopPromise<PSQLRowStream>,
result: QueryResult,
context: ChannelHandlerContext
) {
Expand All @@ -582,7 +582,7 @@ final class PostgresChannelHandler: ChannelDuplexHandler {
)
}

rowsPromise.succeed(rows)
promise.succeed(rows)
}

private func closeConnectionAndCleanup(
Expand Down

0 comments on commit b966180

Please sign in to comment.