public CompletableFuture apply()

in java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreetingsFn.java [50:62]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  public CompletableFuture<Void> apply(Context context, Message message) {
    if (message.is(USER_PROFILE_PROTOBUF_TYPE)) {
      final UserProfile profile = message.as(USER_PROFILE_PROTOBUF_TYPE);
      final String greetings = createGreetingsMessage(profile);
      final EgressRecord egressRecord = new EgressRecord("greetings", greetings);

      context.send(
          EgressMessageBuilder.forEgress(PLAYGROUND_EGRESS)
              .withCustomType(EGRESS_RECORD_JSON_TYPE, egressRecord)
              .build());
    }
    return context.done();
  }