more generic implementation

dart-lang · Jan 28, 2025 · d055407 · d055407
1 parent f84fab1
commit d055407
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/pkgs/async/lib/src/subscription_stream.dart b/pkgs/async/lib/src/subscription_stream.dart
@@ -76,13 +76,9 @@ class _CancelOnErrorSubscriptionWrapper<T>
     super.onError((Object error, StackTrace stackTrace) {
       // Wait for the cancel to complete before sending the error event.
       super.cancel().whenComplete(() {
-        if (handleError is ZoneBinaryCallback<void, Object, StackTrace>) {
+        if (handleError is dynamic Function(Object, StackTrace)) {
           handleError(error, stackTrace);
-        } else if (handleError is ZoneBinaryCallback) {
-          handleError(error, stackTrace);
-        } else if (handleError is ZoneUnaryCallback<void, Object>) {
-          handleError(error);
-        } else if (handleError is ZoneUnaryCallback) {
+        } else if (handleError is dynamic Function(Object)) {
           handleError(error);
         }
       });