14
14
import reactor .core .scheduler .Scheduler ;
15
15
16
16
/**
17
- * <b><class short description - 1 Line!></b>
17
+ * Implementation of the {@link AsyncProjectService} interface.
18
+ * <p>
19
+ * This is the class that should make the actual individual service orchestration and gets all
20
+ * services injected.
18
21
*
19
- * <p><More detailed description - When to use, what it solves, etc.></p>
20
- *
21
- * @since <version tag>
22
+ * @since 1.9.0
22
23
*/
23
24
@ Service
24
25
public class AsyncProjectServiceImpl implements AsyncProjectService {
@@ -40,7 +41,8 @@ public Mono<ProjectUpdateResponse> update(@NonNull ProjectUpdateRequest request)
40
41
case ProjectDesign design :
41
42
return
42
43
withSecurityContext (SecurityContextHolder .getContext (),
43
- () -> updateProjectDesign (projectId , design , request .requestId ())).subscribeOn (scheduler );
44
+ () -> updateProjectDesign (projectId , design , request .requestId ())).subscribeOn (
45
+ scheduler );
44
46
default :
45
47
return Mono .error (new UnknownRequestException ("Invalid request body" ));
46
48
}
@@ -59,7 +61,8 @@ private Mono<ProjectUpdateResponse> withSecurityContext(SecurityContext sctx,
59
61
}).contextWrite (rcontext );
60
62
}
61
63
62
- private Mono <ProjectUpdateResponse > updateProjectDesign (String projectId , ProjectDesign design , String requestId ) {
64
+ private Mono <ProjectUpdateResponse > updateProjectDesign (String projectId , ProjectDesign design ,
65
+ String requestId ) {
63
66
return Mono .create (sink -> {
64
67
try {
65
68
var id = ProjectId .parse (projectId );
0 commit comments