fix: bug when sender blocks if no msgs chan provided

SpatiumPortae · Feb 15, 2023 · 79676f7 · 79676f7
1 parent a455d10
commit 79676f7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/sender/sender.go b/internal/sender/sender.go
@@ -120,7 +120,9 @@ func transferSequence(tc conn.Transfer, payload io.Reader, payloadSize int64, ms
 		return err
 	}
 
-	msgs[0] <- transfer.ReceiverRequestPayload
+	if len(msgs) > 0 {
+		msgs[0] <- transfer.ReceiverRequestPayload
+	}
 
 	if err := transferPayload(tc, payload, payloadSize, msgs...); err != nil {
 		return err