Delay errors

This commit is contained in:
Andrea Cavalli 2023-03-02 18:23:36 +01:00
parent 256e3daf84
commit 6396415b0a

View File

@ -106,7 +106,7 @@ public class FileSponge implements URLsHandler {
for (URLsWriter urlsWriter : cw) {
cacheWriteActions.add(urlsWriter.writeContentBlock(url, dataBlock));
}
return Mono.when(cacheWriteActions).thenReturn(dataBlock);
return Mono.whenDelayError(cacheWriteActions).thenReturn(dataBlock);
})
);
}
@ -151,7 +151,7 @@ public class FileSponge implements URLsHandler {
for (URLsWriter urlsWriter : cw) {
cacheWriteActions.add(urlsWriter.writeMetadata(url, meta));
}
return Mono.when(cacheWriteActions).thenReturn(meta);
return Mono.whenDelayError(cacheWriteActions).thenReturn(meta);
})
);
}