From 6253092a2fac45dcbead199c20787d57fcefb299 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 21 Feb 2023 09:20:47 -0600 Subject: [PATCH] closing pipe reader when data is finished? --- ctl/broadcast.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/ctl/broadcast.go b/ctl/broadcast.go index 6de80f688..82e21441b 100644 --- a/ctl/broadcast.go +++ b/ctl/broadcast.go @@ -16,9 +16,12 @@ func (b *Broadcaster) Consume() { return } io.Copy(ioutil.Discard, b.source) - for _, cl := range b.Writers { - c := cl.(io.WriteCloser) - c.Close() + // maybe acknolwede completfe? but it doesn't know its complete + for i := range b.Writers { + r := b.Readers[i].(*io.PipeReader) + w := b.Writers[i].(*io.PipeWriter) + r.Close() + w.Close() } }