@@ -27,8 +27,10 @@ DaemonMessage _sdtOutLineToMessage(String rawMessage) {
27
27
/// via its stdin and stdout.
28
28
class DaemonStdioHelper {
29
29
DaemonStdioHelper (this .daemonProcess) {
30
- subscription =
31
- daemonProcess.stdout.transform (utf8.decoder).listen (_handleStdoutLine);
30
+ subscription = daemonProcess.stdout
31
+ .transform (utf8.decoder)
32
+ .transform (const LineSplitter ())
33
+ .listen (_handleStdoutLine);
32
34
}
33
35
34
36
final Process daemonProcess;
@@ -40,22 +42,19 @@ class DaemonStdioHelper {
40
42
Matcher ? messageMatcher;
41
43
Completer <String >? messageCompleter;
42
44
43
- void _handleStdoutLine (String lines ) {
45
+ void _handleStdoutLine (String line ) {
44
46
final messageMatcher = this .messageMatcher;
45
47
46
- final linesSplit = lines.split ('\n ' );
47
-
48
- for (final line in linesSplit.where ((element) => element.isNotEmpty)) {
49
- stdout.writeln ('::debug:: <- $line ' );
50
- if (messageMatcher != null ) {
51
- if (messageMatcher.matches (line, {})) {
52
- messageCompleter? .complete (line);
53
- _pastMessagesCache.clear ();
54
- return ;
55
- }
48
+ stdout.writeln ('::debug:: <- $line ' );
49
+ if (messageMatcher != null ) {
50
+ if (messageMatcher.matches (line, {})) {
51
+ messageCompleter? .complete (line);
52
+ _pastMessagesCache.clear ();
53
+ return ;
56
54
}
57
- _pastMessagesCache.add (line);
58
55
}
56
+
57
+ _pastMessagesCache.add (line);
59
58
}
60
59
61
60
void _clean () {
0 commit comments