From efb9588a36872c30bfaf5ea685d2ca1f1a741af3 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 29 Jun 2021 14:01:06 +0100
Subject: [PATCH] Don't block on RS input API

---
 roomserver/internal/input/input.go | 24 +++++++++++++-----------
 1 file changed, 13 insertions(+), 11 deletions(-)

diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index b8279a86..d135a9f4 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -166,17 +166,19 @@ func (r *Inputer) InputRoomEvents(
 		worker.input.push(tasks[i])
 	}
 
-	// Wait for all of the workers to return results about our tasks.
-	wg.Wait()
+	/*
+		// Wait for all of the workers to return results about our tasks.
+		wg.Wait()
 
-	// If any of the tasks returned an error, we should probably report
-	// that back to the caller.
-	for _, task := range tasks {
-		if task.err != nil {
-			response.ErrMsg = task.err.Error()
-			_, rejected := task.err.(*gomatrixserverlib.NotAllowed)
-			response.NotAllowed = rejected
-			return
+		// If any of the tasks returned an error, we should probably report
+		// that back to the caller.
+		for _, task := range tasks {
+			if task.err != nil {
+				response.ErrMsg = task.err.Error()
+				_, rejected := task.err.(*gomatrixserverlib.NotAllowed)
+				response.NotAllowed = rejected
+				return
+			}
 		}
-	}
+	*/
 }