Compare commits
1 Commits
3d57007074
...
a7818fbebc
| Author | SHA1 | Date | |
|---|---|---|---|
| a7818fbebc |
@@ -58,7 +58,7 @@ public class StreamController {
|
|||||||
Optional<Stream> stream = streamService.getActiveStream();
|
Optional<Stream> stream = streamService.getActiveStream();
|
||||||
return stream.map(value -> ResponseEntity.ok(new APIResponse<>(SUCCESS,
|
return stream.map(value -> ResponseEntity.ok(new APIResponse<>(SUCCESS,
|
||||||
"Streaming status retrieved",
|
"Streaming status retrieved",
|
||||||
new StreamResponse(true, value.getId())))).orElseGet(() -> ResponseEntity.ok(new APIResponse<>(SUCCESS,
|
new StreamResponse(true, value.getId())))).orElseGet(() -> ResponseEntity.ok(new APIResponse<>("success",
|
||||||
"Streaming status retrieved",
|
"Streaming status retrieved",
|
||||||
new StreamResponse(false, null))));
|
new StreamResponse(false, null))));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -76,13 +76,9 @@ public class StreamActionsService {
|
|||||||
progressTracker.markComplete();
|
progressTracker.markComplete();
|
||||||
|
|
||||||
return CompletableFuture.completedFuture(outputFile);
|
return CompletableFuture.completedFuture(outputFile);
|
||||||
} catch (IOException e) {
|
} catch (IOException | InterruptedException e) {
|
||||||
logger.error("Failed to save section to '{}'", outputFile, e);
|
logger.error("Failed to save section to '{}'", outputFile, e);
|
||||||
return CompletableFuture.failedFuture(e);
|
return CompletableFuture.failedFuture(e);
|
||||||
} catch (InterruptedException e) {
|
|
||||||
logger.error("Failed to save section");
|
|
||||||
Thread.currentThread().interrupt();
|
|
||||||
return CompletableFuture.failedFuture(e);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user