Skip to content

Commit 10cb1d6

Browse files
committed
Refactoring.
1 parent 24b8686 commit 10cb1d6

File tree

1 file changed

+4
-19
lines changed

1 file changed

+4
-19
lines changed

src/main/java/io/eigr/spawn/internal/transport/server/ActorServiceHandler.java

Lines changed: 4 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -206,25 +206,10 @@ private Optional<Entity> getEntityByActor(String actor, String parent) {
206206
private Protocol.Workflow buildWorkflow(Value valueResponse) {
207207
Protocol.Workflow.Builder workflowBuilder = Protocol.Workflow.newBuilder();
208208

209-
if (valueResponse.getBroadcast().isPresent()) {
210-
Protocol.Broadcast b = valueResponse.getBroadcast().get().build();
211-
workflowBuilder.setBroadcast(b);
212-
}
213-
214-
if (valueResponse.getForward().isPresent()) {
215-
Protocol.Forward f = valueResponse.getForward().get().build();
216-
workflowBuilder.setForward(f);
217-
}
218-
219-
if (valueResponse.getPipe().isPresent()) {
220-
Protocol.Pipe p = valueResponse.getPipe().get().build();
221-
workflowBuilder.setPipe(p);
222-
}
223-
224-
if (valueResponse.getEffects().isPresent()) {
225-
List<SideEffect<?>> efs = valueResponse.getEffects().get();
226-
workflowBuilder.addAllEffects(getProtocolEffects(efs));
227-
}
209+
valueResponse.getBroadcast().ifPresent(b -> workflowBuilder.setBroadcast(b.build()));
210+
valueResponse.getForward().ifPresent(f -> workflowBuilder.setForward(f.build()));
211+
valueResponse.getPipe().ifPresent(p -> workflowBuilder.setPipe(p.build()));
212+
valueResponse.getEffects().ifPresent(e -> workflowBuilder.addAllEffects(getProtocolEffects(e)));
228213

229214
return workflowBuilder.build();
230215
}

0 commit comments

Comments
 (0)