diff --git a/internal/multiplex/bufferedPipe.go b/internal/multiplex/bufferedPipe.go
index ea3f87e..7652cc9 100644
--- a/internal/multiplex/bufferedPipe.go
+++ b/internal/multiplex/bufferedPipe.go
@@ -92,9 +92,8 @@ func (p *bufferedPipe) WriteTo(w io.Writer) (n int64, err error) {
 				return n, er
 			}
 			p.rwCond.Broadcast()
-		} else {
-			p.rwCond.Wait()
 		}
+		p.rwCond.Wait()
 	}
 }
 
diff --git a/internal/multiplex/datagramBuffer.go b/internal/multiplex/datagramBuffer.go
index e802e0a..c3ea771 100644
--- a/internal/multiplex/datagramBuffer.go
+++ b/internal/multiplex/datagramBuffer.go
@@ -98,9 +98,8 @@ func (d *datagramBuffer) WriteTo(w io.Writer) (n int64, err error) {
 				return n, er
 			}
 			d.rwCond.Broadcast()
-		} else {
-			d.rwCond.Wait()
 		}
+		d.rwCond.Wait()
 	}
 }