public static String getEmulatorEndpoint()

in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java [34:44]

• 10 lines of code
• 4 McCabe index (conditional complexity)

  public static String getEmulatorEndpoint(Optional<String> endpoint) {
    String emulatorEndpoint = null;
    // Prioritize using an emulator endpoint set in env var PUBSUB_EMULATOR_HOST.
    if ((emulatorEndpoint = System.getenv("PUBSUB_EMULATOR_HOST")) != null) {
      return emulatorEndpoint;
    }
    if (endpoint.isPresent() && endpoint.get().startsWith(EMULATOR_ENDPOINT_PREFIX)) {
      return endpoint.get().replaceFirst(EMULATOR_ENDPOINT_PREFIX, "");
    }
    return emulatorEndpoint;
  }