From 0938471d1c6d65d3c0efb72dd033fdb05faaf566 Mon Sep 17 00:00:00 2001 From: Juan Batiz-Benet Date: Wed, 24 Dec 2014 05:50:05 -0800 Subject: [PATCH] ctxio: fix buffer of 1 so goroutine exits when io completes. --- util/ctx/ctxio.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/util/ctx/ctxio.go b/util/ctx/ctxio.go index 56057cdd2..0b41086df 100644 --- a/util/ctx/ctxio.go +++ b/util/ctx/ctxio.go @@ -45,7 +45,7 @@ func (w *ctxWriter) Write(buf []byte) (int, error) { buf2 := make([]byte, len(buf)) copy(buf2, buf) - c := make(chan ioret) + c := make(chan ioret, 1) go func() { n, err := w.w.Write(buf2) @@ -92,7 +92,7 @@ func NewReader(ctx context.Context, r io.Reader) *ctxReader { func (r *ctxReader) Read(buf []byte) (int, error) { buf2 := make([]byte, len(buf)) - c := make(chan ioret) + c := make(chan ioret, 1) go func() { n, err := r.r.Read(buf2)