diff --git a/backends/backends.go b/backends/backends.go
index 1272bca5c1..1c7d76ecc5 100644
--- a/backends/backends.go
+++ b/backends/backends.go
@@ -77,6 +77,7 @@ func Splice(dst beam.Sender, msg *beam.Message, r beam.Receiver, w beam.Sender)
 		go func() {
 			defer tasks.Done()
 			beamutils.Copy(dst, src)
+			dst.Close()
 		}()
 	}
 	_copy(dstW, r)