fix code for Dart-2.5

achilleasa · Sep 17, 2019 · 2e48c8e · 2e48c8e
1 parent ac925e6
commit 2e48c8e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -1,4 +1,5 @@
 language: dart
+dist: trusty
 services:
   - rabbitmq
 jobs:

diff --git a/lib/src/client/impl/client_impl.dart b/lib/src/client/impl/client_impl.dart
@@ -41,8 +41,9 @@ class _ClientImpl implements Client {
       _socket = s;
 
       // Bind processors and initiate handshake
-      _socket
-          .transform(RawFrameParser(tuningSettings).transformer)
+      RawFrameParser(tuningSettings)
+          .transformer
+          .bind(_socket)
           .transform(AmqpMessageDecoder().transformer)
           .listen(_handleMessage,
               onError: _handleException,

diff --git a/test/test_coverage.sh b/test/test_coverage.sh
@@ -15,7 +15,7 @@ rm -f coverage/coverage.lcov
 rm -f coverage/filtered.lcov
 
 # Run tests in checked mode and start observatory; block when tests complete so we can collect coverage data
-dart --enable-vm-service --pause-isolates-on-exit run_all.dart > /dev/null &
+dart --disable-service-auth-codes --enable-vm-service --pause-isolates-on-exit run_all.dart > /dev/null &
 
 # Run coverage collection tool
 echo "Waiting for unit tests to run..."