From 7d2935fd3592c3b5b5e241bb6e5a8fc54aa7c448 Mon Sep 17 00:00:00 2001
From: aleksander-vedvik <vedvik.aleksander@gmail.com>
Date: Sat, 15 Jun 2024 13:04:07 +0200
Subject: [PATCH] fix(broadcast): added cancel to processor

---
 broadcast/processor.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broadcast/processor.go b/broadcast/processor.go
index 289dbf70..55f22e5a 100644
--- a/broadcast/processor.go
+++ b/broadcast/processor.go
@@ -175,6 +175,9 @@ func (p *BroadcastProcessor) handleMsg(new *Content, metadata *metadata) bool {
 		return false
 	}
 	if new.IsCancellation {
+		if p.cancellationCtxCancel != nil {
+			p.cancellationCtxCancel()
+		}
 		// the cancellation implementation is just an
 		// empty function and does not need the ctx or
 		// broadcastChan.