mirror of
https://github.com/square/okhttp.git
synced 2026-01-12 10:23:16 +03:00
Make a defensive copy in InMemoryFileSystem (#8061)
This commit is contained in:
@@ -35,6 +35,9 @@ class InMemoryFileSystem : FileSystem, TestRule {
|
||||
private val openSources = IdentityHashMap<Source, File>()
|
||||
private val openSinks = IdentityHashMap<Sink, File>()
|
||||
|
||||
val allPaths: Set<File>
|
||||
get() = files.keys.toSet()
|
||||
|
||||
override fun apply(base: Statement, description: Description): Statement {
|
||||
return object : Statement() {
|
||||
override fun evaluate() {
|
||||
@@ -119,7 +122,4 @@ class InMemoryFileSystem : FileSystem, TestRule {
|
||||
}
|
||||
|
||||
override fun toString() = "InMemoryFileSystem"
|
||||
fun allPaths(): MutableSet<File> {
|
||||
return files.keys
|
||||
}
|
||||
}
|
||||
|
||||
@@ -317,7 +317,7 @@ public final class CacheTest {
|
||||
Response response1 = client.newCall(request).execute();
|
||||
assertThat(response1.body().string()).isEqualTo("ABC");
|
||||
|
||||
File cacheEntry = fileSystem.allPaths().stream()
|
||||
File cacheEntry = fileSystem.getAllPaths().stream()
|
||||
.filter((e) -> e.getName().endsWith(".0"))
|
||||
.findFirst()
|
||||
.orElseThrow(Exception::new);
|
||||
|
||||
Reference in New Issue
Block a user