Close file stream

This commit is contained in:
René Pfeuffer
2019-06-21 15:04:45 +02:00
parent 75cd5165e3
commit 56996395f1

View File

@@ -11,6 +11,7 @@ import javax.inject.Inject;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.util.stream.Stream;
public class JAXBPropertyFileAccess implements PropertyFileAccess {
@@ -43,7 +44,8 @@ public class JAXBPropertyFileAccess implements PropertyFileAccess {
public void forStoreFiles(FileConsumer storeFileConsumer) throws IOException {
Path v1storeDir = computeV1StoreDir();
if (Files.exists(v1storeDir) && Files.isDirectory(v1storeDir)) {
Files.list(v1storeDir).filter(p -> p.toString().endsWith(XML_FILENAME_SUFFIX)).forEach(p -> {
try (Stream<Path> fileStream = Files.list(v1storeDir)) {
fileStream.filter(p -> p.toString().endsWith(XML_FILENAME_SUFFIX)).forEach(p -> {
try {
String storeName = extractStoreName(p);
storeFileConsumer.accept(p, storeName);
@@ -53,6 +55,7 @@ public class JAXBPropertyFileAccess implements PropertyFileAccess {
});
}
}
}
@Override
public void moveAsRepositoryStore(Path storeFile, String repositoryId) throws IOException {