Handle interrupted exception at task level (#785)

Author: pivovarit

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();