Index: lib/src/backend/live_test_controller.dart |
diff --git a/lib/src/backend/live_test_controller.dart b/lib/src/backend/live_test_controller.dart |
index a1543157edb204d2ac0c510aa887db6cadb2a05f..5e80c73e96acee583ba17a3e1650f417b2de3df1 100644 |
--- a/lib/src/backend/live_test_controller.dart |
+++ b/lib/src/backend/live_test_controller.dart |
@@ -9,6 +9,7 @@ import 'package:stack_trace/stack_trace.dart'; |
import 'group.dart'; |
import 'live_test.dart'; |
+import 'message.dart'; |
import 'state.dart'; |
import 'suite.dart'; |
import 'test.dart'; |
@@ -32,7 +33,7 @@ class _LiveTest extends LiveTest { |
Stream<AsyncError> get onError => _controller._onErrorController.stream; |
- Stream<String> get onPrint => _controller._onPrintController.stream; |
+ Stream<Message> get onMessage => _controller._onMessageController.stream; |
Future get onComplete => _controller.completer.future; |
@@ -94,11 +95,12 @@ class LiveTestController { |
final _onErrorController = new StreamController<AsyncError> |
.broadcast(sync: true); |
- /// The controller for [LiveTest.onPrint]. |
+ /// The controller for [LiveTest.onMessage]. |
/// |
/// This is synchronous to ensure that events are well-ordered across multiple |
/// streams. |
- final _onPrintController = new StreamController<String>.broadcast(sync: true); |
+ final _onMessageController = |
+ new StreamController<Message>.broadcast(sync: true); |
/// The completer for [LiveTest.onComplete]; |
final completer = new Completer(); |
@@ -162,14 +164,14 @@ class LiveTestController { |
_onStateChangeController.add(newState); |
} |
- /// Emits a line printed by the test over [LiveTest.onPrint]. |
- void print(String line) { |
- if (_onPrintController.hasListener) { |
- _onPrintController.add(line); |
+ /// Emits message over [LiveTest.onMessage]. |
+ void message(Message message) { |
+ if (_onMessageController.hasListener) { |
+ _onMessageController.add(message); |
} else { |
- // Make sure all prints get surfaced one way or another to aid in |
+ // Make sure all messages get surfaced one way or another to aid in |
// debugging. |
- Zone.ROOT.print(line); |
+ Zone.ROOT.print(message.text); |
} |
} |