Deboa Extras

Additional functionality for the Deboa HTTP client, including serializers, compression, websockets and sse support.

Installation

[dependencies]
deboa-extras = { version = "0.0.5", features = ["json", "websocket", "sse"] }

Features

• json (default)
• msgpack (default)
• xml (default)
• yaml
• flex
• cbor
• sse (default)
• utils (default)

Examples

JSON Serialization/Deserialization

use deboa_extras::serde::json::JsonBody;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize)]
struct User {
    id: u64,
    name: String,
}

// Serialize request body
let user = User { id: 1, name: "John Doe".to_string() };
let request = deboa::post("https://api.example.com/users")
    .body_as(JsonBody, &user)?;

// Deserialize response
let response: User = request
    .send_with(&client)
    .await?
    .body_as(JsonBody)?;

SSE

use deboa::{Client, Result};
use deboa_extras::http::sse::response::{IntoEventStream};

let client = Client::new();

let response = client.execute("https://sse.dev/test").await?.into_event_stream();

// Poll events, until the connection is closed
// please note that this is a blocking call
while let Some(event) = response.next().await {
    println!("event: {}", event);
}

println!("Connection closed");

API Reference

For detailed API documentation, see the docs.rs page.