import 'package:dartz/dartz.dart';
final tasks = List.generate(10, (i) => i);
final computeTask = (int n) async {
final duration = Duration(milliseconds: n != 5 ? 2000 : 10);
await Future.delayed(duration);
return n;
};
final result = await IO.race(tasks, computeTask).unsafeRun();
expect(true, result.nonEmpty);
expect(5, result.get());
-
Notifications
You must be signed in to change notification settings - Fork 0
Dart IO Monad Runtime
License
mobilemindtech/dartz
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
Dart IO Monad Runtime
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published