Fix SSL connection handler. (#271)

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## 3.0.4
+
+- Fix: SSL connection problem handler.
+
 ## 3.0.3
 
 - Using const for ConnectionSettings, SessionSettings and PoolSettings classes. ([#267](https://github.com/isoos/postgresql-dart/pull/267) by [Gerrel](https://github.com/Gerrel))

lib/src/v3/connection.dart

@@ -243,6 +243,9 @@ class PgConnectionImplementation extends _PgSessionBase implements Connection {
     // ignore: cancel_subscriptions
     final subscription = socket.listen(
       (data) {
+        if (sslCompleter.isCompleted) {
+          return;
+        }
         if (data.length != 1) {
           sslCompleter.completeError(PgException(
               'Could not initialize SSL connection, received unknown byte stream.'));
@@ -251,9 +254,19 @@ class PgConnectionImplementation extends _PgSessionBase implements Connection {
 
         sslCompleter.complete(data.first);
       },
-      onDone: () => sslCompleter.completeError(PgException(
-          'Could not initialize SSL connection, connection closed during handshake.')),
-      onError: sslCompleter.completeError,
+      onDone: () {
+        if (sslCompleter.isCompleted) {
+          return;
+        }
+        sslCompleter.completeError(PgException(
+            'Could not initialize SSL connection, connection closed during handshake.'));
+      },
+      onError: (e) {
+        if (sslCompleter.isCompleted) {
+          return;
+        }
+        sslCompleter.completeError(e);
+      },
     );
 
     Stream<Uint8List> adaptedStream;

pubspec.yaml

@@ -1,6 +1,6 @@
 name: postgres
 description: PostgreSQL database driver. Supports statement reuse and binary protocol and connection pooling.
-version: 3.0.3
+version: 3.0.4
 homepage: https://github.com/isoos/postgresql-dart
 topics:
   - sql