Fixed potential nil pointer

noctarius · Jul 11, 2023 · 73e5462 · 73e5462
1 parent d6c75d4
commit 73e5462
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/replication/context/dispatcher.go b/internal/replication/context/dispatcher.go
@@ -195,7 +195,9 @@ func (d *dispatcher) StartDispatcher() {
 			case <-d.shutdownAwaiter.AwaitShutdownChan():
 				goto finish
 			case task := <-d.taskQueue.ReadChannel():
-				task(notificator)
+				if task != nil {
+					task(notificator)
+				}
 			}
 		}