This repository was archived by the owner on Nov 1, 2024. It is now read-only.
File tree Expand file tree Collapse file tree 4 files changed +13
-10
lines changed Expand file tree Collapse file tree 4 files changed +13
-10
lines changed Original file line number Diff line number Diff line change
1
+ ## 0.1.5
2
+
3
+ * Change TestStdinAsync.controller to StreamController<List<int >> (instead of
4
+ using dynamic as the type argument).
5
+
1
6
## 0.1.4
2
7
3
8
* Added ` BazelWorkerDriver ` class, which can be used to implement the bazel side
Original file line number Diff line number Diff line change @@ -50,8 +50,8 @@ class TestStdinSync implements TestStdin {
50
50
/// Note: You must call [close] in order for the loop to exit properly.
51
51
class TestStdinAsync implements TestStdin {
52
52
/// Controls the stream for async delivery of bytes.
53
- final StreamController _controller = new StreamController ();
54
- StreamController get controller => _controller;
53
+ final StreamController < List < int >> _controller = new StreamController ();
54
+ StreamController < List < int >> get controller => _controller;
55
55
56
56
/// Adds all the [bytes] to this stream.
57
57
void addInputBytes (List <int > bytes) {
@@ -67,9 +67,7 @@ class TestStdinAsync implements TestStdin {
67
67
StreamSubscription <List <int >> listen (onData (List <int > bytes),
68
68
{Function onError, void onDone (), bool cancelOnError}) {
69
69
return _controller.stream.listen (onData,
70
- onError: onError,
71
- onDone: onDone,
72
- cancelOnError: cancelOnError) as StreamSubscription <List <int >>;
70
+ onError: onError, onDone: onDone, cancelOnError: cancelOnError);
73
71
}
74
72
75
73
@override
Original file line number Diff line number Diff line change 1
1
name : bazel_worker
2
- version : 0.1.4
2
+ version : 0.1.5
3
3
description : Tools for creating a bazel persistent worker.
4
4
author :
Dart Team <[email protected] >
5
5
homepage : https://github.com/dart-lang/bazel_worker
Original file line number Diff line number Diff line change @@ -48,13 +48,13 @@ void main() {
48
48
});
49
49
}
50
50
51
- void runTests/* <T extends TestWorkerConnection>*/ (
51
+ void runTests <T extends TestWorkerConnection >(
52
52
TestStdin stdinFactory (),
53
- /*=T*/ workerConnectionFactory (Stdin stdin, Stdout stdout),
54
- TestWorkerLoop workerLoopFactory (/*=T*/ connection)) {
53
+ T workerConnectionFactory (Stdin stdin, Stdout stdout),
54
+ TestWorkerLoop workerLoopFactory (T connection)) {
55
55
TestStdin stdinStream;
56
56
TestStdoutStream stdoutStream;
57
- var /*=T*/ connection;
57
+ T connection;
58
58
TestWorkerLoop workerLoop;
59
59
60
60
setUp (() {
You can’t perform that action at this time.
0 commit comments