We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a117d11 commit d37465dCopy full SHA for d37465d
Sources/PostgresNIO/Connection/PostgresConnection.swift
@@ -463,8 +463,9 @@ extension PostgresConnection {
463
self.channel.write(HandlerTask.extendedQuery(context), promise: nil)
464
465
do {
466
- let rowStream = try await promise.futureResult.get()
467
- let rowSequence = rowStream.asyncSequence()
+ let (rowStream, rowSequence) = try await promise.futureResult.map { rowStream in
+ (rowStream, rowStream.asyncSequence())
468
+ }.get()
469
let result = try await consume(rowSequence)
470
try await rowStream.drain().get()
471
guard let metadata = PostgresQueryMetadata(string: rowStream.commandTag) else {
0 commit comments