librqbit 8.1.1

The main library used by rqbit torrent client. The binary is just a small wrapper on top of it.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use axum::{extract::State, response::IntoResponse};
use futures::TryStreamExt;
use tracing::debug;

use super::ApiState;
use crate::api::Result;

pub async fn h_set_rust_log(
    State(state): State<ApiState>,
    new_value: String,
) -> Result<impl IntoResponse> {
    state.api.api_set_rust_log(new_value).map(axum::Json)
}

pub async fn h_stream_logs(State(state): State<ApiState>) -> Result<impl IntoResponse> {
    let s = state.api.api_log_lines_stream()?.map_err(|e| {
        debug!(error=%e, "stream_logs");
        e
    });
    Ok(axum::body::Body::from_stream(s))
}