diff --git a/core/file_caches.go b/core/file_caches.go index c0be7a70..ce742488 100644 --- a/core/file_caches.go +++ b/core/file_caches.go @@ -105,7 +105,7 @@ func (fc *fileCache) Get(ctx context.Context, arg fmt.Stringer) (*CachedStream, } // All other cases, just return a Reader, without Seek capabilities - return &CachedStream{Reader: r, Cached: true}, nil + return &CachedStream{Reader: r, Cached: cached}, nil } func (fc *fileCache) Ready() bool { diff --git a/core/file_caches_test.go b/core/file_caches_test.go index 4d3f19ae..deca9177 100644 --- a/core/file_caches_test.go +++ b/core/file_caches_test.go @@ -60,6 +60,7 @@ var _ = Describe("File Caches", func() { // First call is a MISS s, err := fc.Get(context.TODO(), &testArg{"test"}) Expect(err).To(BeNil()) + Expect(s.Cached).To(BeFalse()) Expect(ioutil.ReadAll(s)).To(Equal([]byte("test"))) // Second call is a HIT @@ -67,6 +68,7 @@ var _ = Describe("File Caches", func() { s, err = fc.Get(context.TODO(), &testArg{"test"}) Expect(err).To(BeNil()) Expect(ioutil.ReadAll(s)).To(Equal([]byte("test"))) + Expect(s.Cached).To(BeTrue()) Expect(called).To(BeFalse()) }) @@ -79,6 +81,7 @@ var _ = Describe("File Caches", func() { // First call is a MISS s, err := fc.Get(context.TODO(), &testArg{"test"}) Expect(err).To(BeNil()) + Expect(s.Cached).To(BeFalse()) Expect(ioutil.ReadAll(s)).To(Equal([]byte("test"))) // Second call is also a MISS @@ -86,6 +89,7 @@ var _ = Describe("File Caches", func() { s, err = fc.Get(context.TODO(), &testArg{"test"}) Expect(err).To(BeNil()) Expect(ioutil.ReadAll(s)).To(Equal([]byte("test"))) + Expect(s.Cached).To(BeFalse()) Expect(called).To(BeTrue()) }) })