55 lines
1.4 KiB
Dart
55 lines
1.4 KiB
Dart
|
import 'dart:async';
|
||
|
|
import 'dart:developer';
|
||
|
|
import 'dart:isolate';
|
||
|
|
|
||
|
|
class IsolateDataLoader<T> {
|
||
|
|
final Future<T> Function() _loadingFunction;
|
||
|
|
|
||
|
|
IsolateDataLoader({
|
||
|
|
required Future<T> Function() loadingFunction,
|
||
|
|
}) : _loadingFunction = loadingFunction;
|
||
|
|
|
||
|
|
Future<T> load() async {
|
||
|
|
final ReceivePort receivePort = ReceivePort("Receive");
|
||
|
|
final isolate = await Isolate.spawn(
|
||
|
|
_isolateEntryPoint, receivePort.sendPort,
|
||
|
|
debugName: "DataLoaderIsolate");
|
||
|
|
|
||
|
|
final completer = Completer<T>();
|
||
|
|
|
||
|
|
receivePort.listen((message) {
|
||
|
|
if (message is SendPort) {
|
||
|
|
message.send(_loadingFunction);
|
||
|
|
} else if (message is T) {
|
||
|
|
completer.complete(message);
|
||
|
|
receivePort.close();
|
||
|
|
isolate.kill();
|
||
|
|
} else if (message is dynamic) {
|
||
|
|
completer.completeError(message);
|
||
|
|
receivePort.close();
|
||
|
|
isolate.kill();
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
return completer.future;
|
||
|
|
}
|
||
|
|
|
||
|
|
static void _isolateEntryPoint(SendPort sendPort) {
|
||
|
|
final port = ReceivePort();
|
||
|
|
sendPort.send(port.sendPort);
|
||
|
|
port.listen((message) async {
|
||
|
|
try {
|
||
|
|
log(message.runtimeType.toString(), name: "RUT");
|
||
|
|
|
||
|
|
final Function loadingFunction = message as Function;
|
||
|
|
|
||
|
|
var result = await loadingFunction();
|
||
|
|
sendPort.send(result);
|
||
|
|
} catch (error, st) {
|
||
|
|
log("ERROR is $error");
|
||
|
|
sendPort.send(error);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|