Fix hang on close

2024-03-10 13:55:29 +01:00 · 2024-03-10 13:55:29 +01:00 · 2b17a34ff7
parent 57c66c4690
commit 2b17a34ff7
1 changed files with 1 additions and 0 deletions
--- a/sender_worker.go
+++ b/sender_worker.go
@ -115,6 +115,7 @@ func NotifyViaHTTP(events <-chan GenericMessage, wg *sync.WaitGroup, logger *log
 				}
 			}
 		}
+		close(returnEvents)
 	}()

 	return returnEvents