From ebfea36f21e1c15d77c58c5d28dd97567023ed6e Mon Sep 17 00:00:00 2001 From: Brad Rydzewski Date: Tue, 12 Apr 2016 17:43:38 -0700 Subject: [PATCH] fix compile error after dep upgrade --- stream/stream_impl.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/stream/stream_impl.go b/stream/stream_impl.go index 11d74ec71..a25a3b155 100644 --- a/stream/stream_impl.go +++ b/stream/stream_impl.go @@ -43,7 +43,7 @@ type mux struct { func (m *mux) Create(key string) (io.ReadCloser, io.WriteCloser, error) { rc, wc, err := m.cache.Get(key) if rc != nil { - rc = &closeOnceReader{ReadCloser: rc} + rc = &closeOnceReader{ReaderAt: rc, ReadCloser: rc} } if wc != nil { wc = &closeOnceWriter{WriteCloser: wc} @@ -67,6 +67,7 @@ func (m *mux) Remove(key string) error { // attempting to close the fscache reader more than // once results in a panic. type closeOnceReader struct { + io.ReaderAt io.ReadCloser once sync.Once }