From d7d4c626020e18e26e069545672acb6cf16361b0 Mon Sep 17 00:00:00 2001
From: Wayback Archiver <66856220+waybackarchiver@users.noreply.github.com>
Date: Sun, 5 Feb 2023 13:32:31 +0000
Subject: [PATCH] Fix execution sequence

---
 relay.go | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/relay.go b/relay.go
index 086f6bd..ad51421 100644
--- a/relay.go
+++ b/relay.go
@@ -230,14 +230,13 @@ func (r *Relay) Publish(ctx context.Context, event Event) Status {
 
 	// publish event
 	if err := r.Connection.WriteJSON([]interface{}{"EVENT", event}); err != nil {
+		// update status (this will be returned later)
+		mu.Lock()
+		status = PublishStatusSent
+		mu.Unlock()
 		return status
 	}
 
-	// update status (this will be returned later)
-	mu.Lock()
-	status = PublishStatusSent
-	mu.Unlock()
-
 	sub := r.Subscribe(ctx, Filters{Filter{IDs: []string{event.ID}}})
 	defer mu.Unlock()
 	for {