| 153 | } |
| 154 | if !c.Has(key) { |
| 155 | t.Fatal("Has should be true after PutStream") |
| 156 | } |
| 157 | r, _, ok := c.Open(key) |
| 158 | if !ok { |
| 159 | t.Fatal("Open should hit after PutStream") |
| 160 | } |
| 161 | defer func() { _ = r.Close() }() |
| 162 | got, _ := io.ReadAll(r) |
| 163 | if string(got) != string(data) { |
| 164 | t.Errorf("Open returned %q, want %q", got, data) |
| 165 | } |
| 166 | } |
| 167 | |
| 168 | func TestDiskCacheOpen(t *testing.T) { |
| 169 | c := newTestCache(t) |
| 170 | key := strings.Repeat("b", 64) |
| 171 | data := []byte("streaming bytes") |
| 172 | if _, err := c.PutStream(key, bytes.NewReader(data)); err != nil { |
| 173 | t.Fatalf("PutStream: %v", err) |
| 174 | } |