Rust
Tämä sivu on käännetty englannista. Jos ne eroavat toisistaan, englanninkielinen sivu on oikea. Lue englanninkielinen sivu
Rust-kirjasto on crates.io-rekisterin crate lingara. Se vaatii Rust 1.87 -version tai uudemman ja toimii Tokio-ajoympäristössä. TLS tulee oletuksena rustls-kirjastosta tai featuren kautta alustan omasta TLS-toteutuksesta.
Miltä se näyttää
- Jokainen kutsu on
async fn, joka palauttaaResult-arvon. Peruuta kutsu pudottamalla sen future; peruuta virta pudottamalla virta. - Virta saapuu heti, kun vastauksen otsakkeet saapuvat, tulosten
Stream-virtana. Lue sitä kutsulla.next().await. - Virheet ovat yksi
Error-enum, jolla on neljä varianttia.Error::retry_afterpalauttaa API:n ilmoittaman odotusajan, jos sellainen oli. - Rakenna asiakas kutsulla
Client::builder(). Jakaaksesi yhteyspoolin anna sille omareqwest::Client, mutta älä anna tälle asiakkaalle kokonaisaikakatkaisua, tai se katkaisee pitkät virrat kesken. Jos haluat määräajan yhdelle kutsulle, kääri setokio::time::timeout-kutsuun.
Alla olevat esimerkit asentavat craten, luovat asiakkaan, virtauttavat sanastoluettelon ja käsittelevät virheen.
Rust
cargo add lingara@0.1.0-alpha.6
cargo add tokio --features macros,rt-multi-threadRust
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()),
}