From b9dbdb2607b903d57558f982c819ec784025b784 Mon Sep 17 00:00:00 2001
From: Grzegorz Piwowarek <gpiwowarek@gmail.com>
Date: Mon, 9 Oct 2023 13:53:09 +0200
Subject: [PATCH] Handle interrupted exception at task level (#785)

---
 src/main/java/com/pivovarit/collectors/Dispatcher.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/pivovarit/collectors/Dispatcher.java b/src/main/java/com/pivovarit/collectors/Dispatcher.java
index 6aaa0e43..f78742ee 100644
--- a/src/main/java/com/pivovarit/collectors/Dispatcher.java
+++ b/src/main/java/com/pivovarit/collectors/Dispatcher.java
@@ -65,6 +65,7 @@ void start() {
                                     task.run();
                                 } catch (InterruptedException e) {
                                     Thread.currentThread().interrupt();
+                                    handle(e);
                                     throw new RuntimeException(e);
                                 } finally {
                                     limiter.release();