Rust

Deze pagina is vertaald uit het Engels. Als de twee verschillen, is de Engelse pagina juist. Lees de Engelse pagina

De Rust-bibliotheek is de crate lingara op crates.io. Ze vereist Rust 1.87 of hoger en draait op de Tokio-runtime. TLS komt standaard van rustls, of via een feature van de eigen TLS van het platform.

Hoe het leest

Elke aanroep is een async fn die een Result teruggeeft. Om een aanroep te annuleren, drop je de future; om een stream te annuleren, drop je de stream.
Een stream komt binnen zodra de response-headers er zijn, als een Stream van resultaten. Lees hem met .next().await.
Fouten zijn één Error-enum met vier varianten. Error::retry_after geeft de wachttijd terug die de API noemde, als die er was.
Bouw een client met Client::builder(). Om een verbindingspool te delen, geef je hem je eigen reqwest::Client, maar geef die client geen totale time-out, anders breekt hij lange streams voortijdig af. Voor een deadline op één aanroep wikkel je die in tokio::time::timeout.

De voorbeelden hieronder installeren de crate, maken een client aan, streamen een woordenlijst en handelen een fout af.

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

Hoe het leest

Wat deze pagina omvat