Fix panics on closed channel sends

S7evinK · Jan 4, 2022 · 85ede6d · 85ede6d
1 parent 9755494
commit 85ede6d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
@@ -119,7 +119,11 @@ func (r *Inputer) InputRoomEvents(
 				} else {
 					hooks.Run(hooks.KindNewEventPersisted, inputRoomEvent.Event)
 				}
-				responses <- err
+				select {
+				case <-ctx.Done():
+				default:
+					responses <- err
+				}
 			})
 		}
 		for i := 0; i < len(request.InputRoomEvents); i++ {