fix for Dart-2.5

changelog.md

@@ -1,5 +1,12 @@
 #Recent change notes
 
+### 0.3.5
+* Updates for Dart 2.5 compatibility. As of Dart 2.5, the `Socket` class
+emits `Uint8List`, rather than plain `List<int>`, so some fixes were necessary
+to allow the package to continue to function.
+  * Courtesy of @a14n, thank you!
+  * Resolves https://github.com/mongo-dart/mongo_dart/issues/160, among other issues.
+
 ### 0.3.4
 * Added `cursor` option to `DbCollection.aggregate`.
   * Courtesy of @jodinathan, thank you!

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);

pubspec.yaml

@@ -1,5 +1,5 @@
 name: mongo_dart
-version: 0.3.4
+version: 0.3.5
 authors:
 - Vadim Tsushko <[email protected]>
 - Ted Sander <[email protected]>

test/database_test.dart

@@ -1323,7 +1323,8 @@ main() {
     });
 
     group('Aggregate:', () {
-      test('testAggregate', testAggregate);
+      test('testAggregate', testAggregate,
+          skip: 'As of MongoDB 3.6, cursor is *required* for aggregate.');
       test('testAggregateWithCursor', testAggregateWithCursor);
       test(
           'testAggregateToStream - if server older then version 2.6 test would be skipped',