Sunra gestiona las solicitudes de los endpoints a través de un sistema de colas, lo que garantiza la fiabilidad y la escalabilidad. Usa el método subscribe para enviar una solicitud y esperar el resultado.Ejemplo:
Copy
import ai.sunra.client.*;import ai.sunra.client.queue.*;import java.util.Map;import com.google.gson.JsonObject;import java.util.function.Consumer;ClientConfig config = ClientConfig.builder() .withCredentials(CredentialsResolver.fromEnv()) .build();SunraClient client = SunraClient.withConfig(config);Map<String, Object> input = Map.of( "prompt", "un perro corriendo en el parque");Consumer<QueueStatus.StatusUpdate> statusUpdateHandler = update -> { String status = update.getStatus().toString(); String message = String.format("\nActualización de estado: %s, ID de solicitud: %s", status, update.getRequestId()); System.out.println(message);};SubscribeOptions<JsonObject> options = SubscribeOptions.<JsonObject>builder() .input(input) .resultType(JsonObject.class) .onQueueUpdate(statusUpdateHandler) .logs(true) .build();// guarda la solicitud de suscripción en una variable e imprímelaOutput<JsonObject> response = client.subscribe("black-forest-labs/flux-kontext-pro/text-to-image", options);System.out.println("¡Completado!");System.out.println(response.getData());