X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/7088b82414bdf947a6f88918c0a7b2c7fb0c53ef..4c199e7d93b6a4529ed5956807911b5f6c5489a7:/turn.go

diff --git a/turn.go b/turn.go
index 40645b1..4288604 100644
--- a/turn.go
+++ b/turn.go
@@ -112,6 +112,7 @@ func (l *TurnLoop) Submit(source, text string) (Message, error) {
 	}
 
 	l.mutex.Lock()
+
 	l.pending = append(l.pending, message)
 	l.mutex.Unlock()
 
@@ -167,6 +168,7 @@ func (l *TurnLoop) Wake(messages ...Message) {
 	}
 
 	l.mutex.Lock()
+
 	l.pending = append(l.pending, messages...)
 	l.mutex.Unlock()
 
@@ -285,6 +287,7 @@ func (l *TurnLoop) waiting() bool {
 // fail stops the loop with err.
 func (l *TurnLoop) fail(err error) {
 	l.mutex.Lock()
+
 	l.failure = errors.Join(l.failure, err)
 	l.mutex.Unlock()
 
@@ -313,11 +316,13 @@ func (l *TurnLoop) turn(ctx context.Context) error {
 	defer cancel()
 
 	l.mutex.Lock()
+
 	l.cancel = cancel
 	l.mutex.Unlock()
 
 	defer func() {
 		l.mutex.Lock()
+
 		l.cancel = nil
 		l.mutex.Unlock()
 	}()