File tree 4 files changed +6
-6
lines changed
examples/concurrency/lib/robust_ports_example
4 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ class Worker {
30
30
_commands.send (message);
31
31
}
32
32
33
- Worker ._(this ._commands , this ._responses ) {
33
+ Worker ._(this ._responses , this ._commands ) {
34
34
// TODO: Initialize main isolate receive port listener.
35
35
}
36
36
Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ class Worker {
30
30
final (ReceivePort receivePort, SendPort sendPort) =
31
31
await connection.future;
32
32
33
- return Worker ._(sendPort, receivePort );
33
+ return Worker ._(receivePort, sendPort );
34
34
}
35
35
// #enddocregion worker-spawn
36
36
@@ -39,7 +39,7 @@ class Worker {
39
39
_commands.send (message);
40
40
}
41
41
42
- Worker ._(this ._commands , this ._responses ) {
42
+ Worker ._(this ._responses , this ._commands ) {
43
43
// TODO: Initialize main isolate receive port listener.
44
44
}
45
45
Original file line number Diff line number Diff line change @@ -18,7 +18,7 @@ class Worker {
18
18
throw UnimplementedError ();
19
19
}
20
20
21
- Worker ._(this ._commands , this ._responses ) {
21
+ Worker ._(this ._responses , this ._commands ) {
22
22
// TODO: Initialize main isolate receive port listener.
23
23
}
24
24
Original file line number Diff line number Diff line change @@ -560,7 +560,7 @@ class Worker {
560
560
throw UnimplementedError();
561
561
}
562
562
563
- Worker._(this._commands , this._responses ) {
563
+ Worker._(this._responses , this._commands ) {
564
564
// TODO: Initialize main isolate receive port listener.
565
565
}
566
566
@@ -689,7 +689,7 @@ class Worker {
689
689
final (ReceivePort receivePort, SendPort sendPort) =
690
690
await connection.future;
691
691
692
- return Worker._(sendPort, receivePort );
692
+ return Worker._(receivePort, sendPort );
693
693
}
694
694
```
695
695
You can’t perform that action at this time.
0 commit comments