fix for Dart-2.5

mongo-dart · Sep 17, 2019 · 8e376be · 8e376be
1 parent c86a68c
commit 8e376be
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 9 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -2,12 +2,6 @@ language: dart
 dart:
   - stable
   - dev
-addons:
-  apt:
-    sources:
-    - mongodb-3.0-precise
-    packages:
-    - mongodb-org-server
 services: mongodb
 before_script:
   - sleep 15

diff --git a/lib/src/network/connection.dart b/lib/src/network/connection.dart
@@ -56,9 +56,8 @@ class _Connection {
     Socket.connect(serverConfig.host, serverConfig.port).then((Socket _socket) {
       // Socket connected.
       socket = _socket;
-      _repliesSubscription = socket
-          .transform(MongoMessageHandler().transformer)
-          .listen(_receiveReply,
+      _repliesSubscription =
+          MongoMessageHandler().transformer.bind(socket).listen(_receiveReply,
               onError: (e, st) {
                 _log.severe("Socket error ${e} ${st}");
                 //completer.completeError(e);