fix: race condition in server mode (#209)

This fixes a race condition, I don't fully understand why though.
charmbracelet · Aug 1, 2023 · 5232ef0 · 5232ef0
1 parent b05a385
commit 5232ef0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/multiplex/reader.go b/multiplex/reader.go
@@ -62,7 +62,7 @@ var (
 
 type syncWriter struct {
 	b  bytes.Buffer
-	mu sync.RWMutex
+	mu sync.Mutex
 }
 
 // Reset implements ResetableReader.
@@ -74,8 +74,8 @@ func (w *syncWriter) Reset() {
 
 // Read implements io.Reader.
 func (w *syncWriter) Read(p []byte) (n int, err error) {
-	w.mu.RLock()
-	defer w.mu.RUnlock()
+	w.mu.Lock()
+	defer w.mu.Unlock()
 	return w.b.Read(p) //nolint: wrapcheck
 }