Skip to content

Commit 2d8559e

Browse files
committed
fix readyForQuery after error
1 parent 9854689 commit 2d8559e

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

Sources/PostgreSQL/Connection/PostgreSQLConnection.swift

+8-8
Original file line numberDiff line numberDiff line change
@@ -25,17 +25,17 @@ public final class PostgreSQLConnection {
2525

2626
/// Sends `PostgreSQLMessage` to the server.
2727
func send(_ messages: [PostgreSQLMessage], onResponse: @escaping (PostgreSQLMessage) throws -> ()) -> Future<Void> {
28+
var error: Error?
2829
return queueStream.enqueue(messages) { message in
2930
switch message {
30-
case .readyForQuery: return true
31-
case .error(let e): throw e
32-
case .notice(let n):
33-
print(n)
34-
return false
35-
default:
36-
try onResponse(message)
37-
return false // request until ready for query
31+
case .readyForQuery:
32+
if let e = error { throw e }
33+
return true
34+
case .error(let e): error = e
35+
case .notice(let n): print(n)
36+
default: try onResponse(message)
3837
}
38+
return false // request until ready for query
3939
}
4040
}
4141

0 commit comments

Comments
 (0)