Rust

Diese Seite ist aus dem Englischen übersetzt. Wenn die beiden voneinander abweichen, ist die englische Seite maßgeblich. Englische Seite lesen

Die Rust-Bibliothek ist das Crate lingara auf crates.io. Sie benötigt Rust 1.87 oder neuer und läuft auf der Tokio-Runtime. TLS kommt standardmäßig von rustls oder, über ein Feature, vom plattformeigenen TLS.

Wie sie sich liest

Jeder Aufruf ist eine async fn, die ein Result zurückgibt. Um einen Aufruf abzubrechen, droppen Sie sein Future; um einen Stream abzubrechen, droppen Sie den Stream.
Ein Stream kommt an, sobald die Antwort-Header ankommen, als Stream von Ergebnissen. Lesen Sie ihn mit .next().await.
Fehler sind ein einziges Error-Enum mit vier Varianten. Error::retry_after gibt die von der API genannte Wartezeit zurück, sofern es eine gab.
Bauen Sie einen Client mit Client::builder(). Um einen Verbindungspool zu teilen, übergeben Sie ihm Ihren eigenen reqwest::Client, geben Sie diesem Client aber kein Gesamt-Timeout, sonst schneidet er lange Streams ab. Für eine Frist bei einem einzelnen Aufruf umschließen Sie ihn mit tokio::time::timeout.

Die folgenden Beispiele installieren das Crate, erstellen einen Client, streamen eine Vokabelliste und behandeln einen Fehler.

Rust

cargo add lingara@0.1.0-alpha.6
cargo add tokio --features macros,rt-multi-thread

Rust

use lingara::Client;

let client = Client::builder()
    .client_credentials(std::env::var("LINGARA_CLIENT_ID")?, std::env::var("LINGARA_CLIENT_SECRET")?)
    .build()?;

Rust

use lingara::models::{GenerateVocabularyEvent, VocabRequest};
use std::num::NonZeroU8;

let request = VocabRequest { level: 2, source_lang: "en".into(), target_lang: "zh".into(), count: NonZeroU8::new(8) };
let mut stream = client.generate_vocabulary(&request).await?;
while let Some(event) = stream.next().await {
    if let GenerateVocabularyEvent::Item(item) = event? {
        println!("{} {}", item.word, item.translation);
    }
}

Rust

use lingara::Error;

let result = client.get_usage().await;
if let Some(wait) = result.as_ref().err().and_then(Error::retry_after) {
    eprintln!("the API asks you to retry after {wait:?}");
}
match result {
    Ok(usage) => println!("{} allowance rows", usage.allowance.len()),
    // A refusal from the API: status, code (stable) and message (localised).
    Err(Error::Api(e)) => eprintln!("{} {} {}", e.status, e.code, e.message),
    // The token endpoint refused the credentials or the scopes.
    Err(Error::OAuth(e)) => eprintln!("{} {} {}", e.status, e.error, e.description.unwrap_or_default()),
    Err(Error::Maintenance(_)) => eprintln!("the API is under maintenance"),
    // No usable answer: connect, tls, reset, timeout, and so on.
    Err(Error::Transport(e)) => eprintln!("transport: {}", e.kind),
    Err(other) => return Err(other.into()),
}

Rust

Wie sie sich liest

Was diese Seite kapselt