Test for pool connection's force close.

isoos · Dec 26, 2024 · e471fef · e471fef
1 parent 090a459
commit e471fef
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/test/pool_test.dart b/test/pool_test.dart
@@ -267,5 +267,21 @@ void main() {
         await expectLater(() => rs, throwsA(isA<PgException>()));
       });
     });
+
+    withPostgresServer('inner connection close', (server) {
+      test('connection from inside withConnection', () async {
+        final pool = await openPool(server);
+        final rs = pool.withConnection((c) async {
+          await Future.wait([
+            Future.delayed(
+              Duration(milliseconds: 200),
+              () => c.close(force: true),
+            ),
+            runLongQuery(c),
+          ]);
+        });
+        await expectLater(() => rs, throwsA(isA<PgException>()));
+      });
+    });
   });
 }