diff --git a/.travis.yml b/.travis.yml
index a0129a8..bd1a1f4 100644
--- 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
index 5bc7f2d..151b54c 100644
--- 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
index d87362e..f9c67d4 100644
--- 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..."