Java
Deze pagina is vertaald uit het Engels. Als de twee verschillen, is de Engelse pagina juist. Lees de Engelse pagina
De Java-bibliotheek is com.getlingara:lingara-java op Maven Central. Ze vereist Java 17 of hoger en gebruikt de eigen java.net.http.HttpClient van de JDK, met Jackson voor JSON.
Hoe het leest
- Aanroepen zijn synchroon. Voor veel tegelijk voer je ze uit op virtual threads of een executor.
- Een stream is een
EventStream, die zowelIterablealsAutoCloseableis: lees hem met eenfor-lus binnen try-with-resources. Events zijn records onder een sealed interface, dus eenswitcherover is uitputtend. - Om te annuleren onderbreek je de thread of roep je
close()aan vanuit een andere thread. De aanroep gooit danCancellationException, wat geen van de fouten van de bibliotheek is. - Fouten breiden
LingaraExceptionuit, een unchecked exception.retryAfter()geeft eenOptional<Duration>terug. - Bouw een client met
LingaraClient.builder(). Een aanroep die niet streamt, heeft geen time-out totdat jerequestTimeoutinstelt.
De voorbeelden hieronder voegen de afhankelijkheid toe, maken een client aan, streamen een woordenlijst en handelen een fout af.
Java
<dependency>
<groupId>com.getlingara</groupId>
<artifactId>lingara-java</artifactId>
<version>0.1.0-alpha.6</version>
</dependency>Java
import com.getlingara.client.LingaraClient;
LingaraClient client =
LingaraClient.builder()
.clientCredentials(
System.getenv("LINGARA_CLIENT_ID"), System.getenv("LINGARA_CLIENT_SECRET"))
.build();Java
import com.getlingara.client.model.GenerateVocabularyEvent;
import com.getlingara.client.model.VocabRequest;
VocabRequest request = new VocabRequest().level(2).sourceLang("en").targetLang("zh").count(8);
try (EventStream<GenerateVocabularyEvent> stream = client.generateVocabulary(request)) {
for (GenerateVocabularyEvent event : stream) {
if (event instanceof GenerateVocabularyEvent.Item item) {
System.out.println(item.data().getWord() + " " + item.data().getTranslation());
}
}
}Java
try {
client.getUsage();
} catch (LingaraException e) {
if (e instanceof ApiException api) {
// A refusal from the API: status(), code() (stable) and getMessage() (localised).
System.out.println(api.status() + " " + api.code() + " " + api.getMessage());
api.retryAfter().ifPresent(wait -> System.out.println("retry after " + wait));
} else if (e instanceof OAuthException oauth) {
// The token endpoint refused the credentials or the scopes.
System.out.println(oauth.status() + " " + oauth.error() + " " + oauth.description());
} else if (e instanceof MaintenanceException maintenance) {
System.out.println("under maintenance");
maintenance.retryAfter().ifPresent(wait -> System.out.println("retry after " + wait));
} else if (e instanceof TransportException transport) {
// No usable answer: CONNECT, TLS, RESET, TIMEOUT, and so on.
System.out.println("transport: " + transport.kind());
}
}
// An interrupted call throws java.util.concurrent.CancellationException instead.