expose AsyncMessageGrouper and SyncMessageGrouper in the testing library (#3)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index ced9768..dd62957 100644
--- a/CHANGELOG.md
+++ b/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.
diff --git a/lib/src/async_message_grouper.dart b/lib/src/async_message_grouper.dart
index a765d55..448f51e 100644
--- a/lib/src/async_message_grouper.dart
+++ b/lib/src/async_message_grouper.dart
@@ -41,4 +41,7 @@
return message;
}
+
+ /// Stop listening to the stream for further updates.
+ Future cancel() => _inputQueue.cancel();
}
diff --git a/lib/testing.dart b/lib/testing.dart
index eed01ba..ecc3142 100644
--- a/lib/testing.dart
+++ b/lib/testing.dart
@@ -8,6 +8,8 @@
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.
diff --git a/pubspec.yaml b/pubspec.yaml
index e2309fa..241861f 100644
--- a/pubspec.yaml
+++ b/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 <misc@dartlang.org>
homepage: https://github.com/dart-lang/bazel_worker
