expose AsyncMessageGrouper and SyncMessageGrouper in the testing library (#3)

Author: jakemac53

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 0.1.1
+
+* Export `AsyncMessageGrouper` and `SyncMessageGrouper` as part of the testing
+  library. These can assist when writing e2e tests and communicating with a
+  worker process.
+
 ## 0.1.0
 
 * Initial version.

lib/src/async_message_grouper.dart

@@ -41,4 +41,7 @@ class AsyncMessageGrouper implements MessageGrouper {
 
     return message;
   }
+
+  /// Stop listening to the stream for further updates.
+  Future cancel() => _inputQueue.cancel();
 }

lib/testing.dart

@@ -8,6 +8,8 @@ import 'dart:io';
 
 import 'package:bazel_worker/bazel_worker.dart';
 
+export 'src/async_message_grouper.dart';
+export 'src/sync_message_grouper.dart';
 export 'src/utils.dart' show protoToDelimitedBuffer;
 
 /// Interface for a mock [Stdin] object that allows you to add bytes manually.

pubspec.yaml

@@ -1,5 +1,5 @@
 name: bazel_worker
-version: 0.1.0
+version: 0.1.1
 description: Tools for creating a bazel persistent worker.
 author: Dart Team <[email protected]>
 homepage: https://github.com/dart-lang/bazel_worker