Liam Appelbe
428b3c4473
Fixes: lib/async/catch_errors6_test lib/async/catch_errors7_test lib/async/catch_errors8_test lib/async/catch_errors_test lib/async/intercept_print1_test lib/async/intercept_schedule_microtask1_test lib/async/intercept_schedule_microtask2_test lib/async/intercept_schedule_microtask3_test lib/async/intercept_schedule_microtask4_test lib/async/intercept_schedule_microtask5_test lib/async/intercept_schedule_microtask6_test lib/async/run_zoned7_test lib/async/run_zoned8_test lib/async/stream_controller_test lib/async/stream_event_transformed_test lib/async/stream_from_iterable_test lib/async/stream_single_test lib/async/stream_single_to_multi_subscriber_test lib/async/stream_state_nonzero_timer_test lib/async/stream_state_test lib/async/stream_transform_test lib/async/stream_transformation_broadcast_test lib/async/stream_transformer_from_bind_test lib/async/stream_transformer_from_handlers_test lib/async/zone_future_schedule_microtask_test lib/async_star/await_for_test lib/async_star/await_pauses_test Change-Id: I9d5d92938c28cc8131c70665ead4d44ffcff6bc5 Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/143001 Commit-Queue: Liam Appelbe <liama@google.com> Reviewed-by: Alexander Markov <alexmarkov@google.com> Reviewed-by: Bob Nystrom <rnystrom@google.com>
56 lines
1.6 KiB
Dart
56 lines
1.6 KiB
Dart
library catch_errors;
|
|
|
|
import 'dart:async';
|
|
|
|
Stream catchErrors(dynamic body()) {
|
|
late StreamController controller;
|
|
|
|
bool onError(e, st) {
|
|
controller.add(e);
|
|
return true;
|
|
}
|
|
|
|
void onListen() {
|
|
runZonedGuarded(body, onError);
|
|
}
|
|
|
|
controller = new StreamController(onListen: onListen);
|
|
return controller.stream;
|
|
}
|
|
|
|
runZonedScheduleMicrotask(body(),
|
|
{void onScheduleMicrotask(void callback())?, Function? onError}) {
|
|
if (onScheduleMicrotask == null) {
|
|
return runZonedGuarded(body, onError as void Function(Object, StackTrace));
|
|
}
|
|
HandleUncaughtErrorHandler? errorHandler;
|
|
if (onError != null) {
|
|
errorHandler = (Zone self, ZoneDelegate parent, Zone zone, error,
|
|
StackTrace stackTrace) {
|
|
try {
|
|
return self.parent!.runUnary(onError as void Function(Object), error);
|
|
} catch (e, s) {
|
|
if (identical(e, error)) {
|
|
return parent.handleUncaughtError(zone, error, stackTrace);
|
|
} else {
|
|
return parent.handleUncaughtError(zone, e, s);
|
|
}
|
|
}
|
|
};
|
|
}
|
|
ScheduleMicrotaskHandler? asyncHandler;
|
|
if (onScheduleMicrotask != null) {
|
|
asyncHandler = (Zone self, ZoneDelegate parent, Zone zone, f()) {
|
|
self.parent!.runUnary(onScheduleMicrotask, () => zone.runGuarded(f));
|
|
};
|
|
}
|
|
ZoneSpecification specification = new ZoneSpecification(
|
|
handleUncaughtError: errorHandler, scheduleMicrotask: asyncHandler);
|
|
Zone zone = Zone.current.fork(specification: specification);
|
|
if (onError != null) {
|
|
return zone.runGuarded(body);
|
|
} else {
|
|
return zone.run(body);
|
|
}
|
|
}
|