A Sunra gerencia as solicitações de endpoint por meio de um sistema de filas, garantindo confiabilidade e escalabilidade. Use o método subscribe para enviar uma solicitação e aguardar o resultado.Exemplo:
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", "um cachorro correndo no parque");Consumer<QueueStatus.StatusUpdate> statusUpdateHandler = update -> { String status = update.getStatus().toString(); String message = String.format("\nAtualização de status: %s, ID da solicitação: %s", status, update.getRequestId()); System.out.println(message);};SubscribeOptions<JsonObject> options = SubscribeOptions.<JsonObject>builder() .input(input) .resultType(JsonObject.class) .onQueueUpdate(statusUpdateHandler) .logs(true) .build();// salve a solicitação de inscrição em uma variável e imprima-aOutput<JsonObject> response = client.subscribe("black-forest-labs/flux-kontext-pro/text-to-image", options);System.out.println("Concluído!");System.out.println(response.getData());