uxum 0.9.3

Opinionated backend service framework based on axum
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Request buffering queue layer.

use std::num::NonZeroUsize;

use serde::{Deserialize, Serialize};
use tower::buffer::BufferLayer;

/// Configuration for request buffering queue layer.
#[derive(Clone, Debug, Deserialize, PartialEq, Serialize)]
pub struct HandlerBufferConfig {
    /// Buffer queue depth.
    pub queue: NonZeroUsize,
}

impl HandlerBufferConfig {
    /// Create layer for use in tower services.
    pub fn make_layer<T>(&self) -> BufferLayer<T> {
        BufferLayer::new(self.queue.into())
    }
}