From 38d8b4eb035cd2856c1eafc8495ed0cf3b74e626 Mon Sep 17 00:00:00 2001 From: Solomon Hykes Date: Mon, 2 Jun 2014 00:22:51 +0000 Subject: [PATCH] Splice: close destination when copy is over --- backends/backends.go | 1 + 1 file changed, 1 insertion(+) 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)