File tree 2 files changed +11
-12
lines changed
2 files changed +11
-12
lines changed Original file line number Diff line number Diff line change @@ -121,26 +121,25 @@ final RegExp partOfRegexp = RegExp('part of ');
121
121
final RegExp newLinePartOfRegexp = RegExp ('\n part of ' );
122
122
123
123
typedef TaskQueueClosure <T > = Future <T > Function ();
124
- typedef CompleteCallback = void Function ();
125
124
126
125
class _TaskQueueItem <T > {
127
- _TaskQueueItem (this .closure , this .completer , {this .onComplete});
126
+ _TaskQueueItem (this ._closure , this ._completer , {this .onComplete});
128
127
129
- final TaskQueueClosure <T > closure ;
130
- final Completer <T > completer ;
131
- CompleteCallback onComplete;
128
+ final TaskQueueClosure <T > _closure ;
129
+ final Completer <T > _completer ;
130
+ void Function () onComplete;
132
131
133
132
Future <void > run () async {
134
133
try {
135
- final result = await closure ();
134
+ final result = await _closure ();
136
135
if (result != null ) {
137
- completer .complete (result);
136
+ _completer .complete (result);
138
137
} else {
139
- completer .complete (null );
138
+ _completer .complete (null );
140
139
}
141
140
await Future <void >.microtask (() {});
142
141
} catch (e) {
143
- completer .completeError (e);
142
+ _completer .completeError (e);
144
143
} finally {
145
144
onComplete? .call ();
146
145
}
Original file line number Diff line number Diff line change @@ -18,10 +18,10 @@ void main() {
18
18
});
19
19
});
20
20
21
- group ('MultiFutureTracker ' , () {
22
- /// A special test designed to check shared [MultiFutureTracker ]
21
+ group ('TaskQueue ' , () {
22
+ /// A special test designed to check shared [TaskQueue ]
23
23
/// behavior when exceptions occur after a delay in the passed closures to
24
- /// [MultiFutureTracker .add] .
24
+ /// [TaskQueue .add] .
25
25
test ('no deadlock when delayed exceptions fire in closures' , () async {
26
26
var sharedTracker = TaskQueue (maxJobs: 2 );
27
27
expect (() async {
You can’t perform that action at this time.
0 commit comments