Struct AFast

Source

pub struct AFast<T, H>where
    T: Clone + Send + Sync + 'static,
    H: AFastKind + AFastData + Send + Sync + 'static,{
    pub middleware: Arc<Box<Middleware<T, H>>>,
    /* private fields */
}

Expand description

Core AFast service struct.

Maintains shared state and registered handlers.

Fields§

§middleware: Arc<Box<Middleware<T, H>>>

Middleware function

Implementations§

Source §

impl<T, H> AFast<T, H>
where T: Clone + Send + Sync + 'static, H: AFastKind + AFastData + Send + Sync + 'static,

Source

pub fn new(state: T) -> Self

Create a new AFast service instance

§Arguments

state - Shared application state
handlers - List of registered handlers

§Returns

A new AFast instance

Examples found in repository ?

examples/test.rs (line 104)

101async fn main() {
102    let state = "".to_string();
103
104    let server = AFast::<String, Header>::new(state)
105        .service("user", "User service", register! { get_user, get_id })
106        .middleware(auth);
107
108    server
109        .serve(
110            #[cfg(feature = "tcp")]
111            &"127.0.0.1:8080",
112            #[cfg(any(feature = "http", feature = "ws"))]
113            &"127.0.0.1:8081",
114        )
115        .await
116        .unwrap();
117}

Source

pub fn middleware(self, middleware: fn() -> Box<Middleware<T, H>>) -> Self

Examples found in repository ?

examples/test.rs (line 106)

101async fn main() {
102    let state = "".to_string();
103
104    let server = AFast::<String, Header>::new(state)
105        .service("user", "User service", register! { get_user, get_id })
106        .middleware(auth);
107
108    server
109        .serve(
110            #[cfg(feature = "tcp")]
111            &"127.0.0.1:8080",
112            #[cfg(any(feature = "http", feature = "ws"))]
113            &"127.0.0.1:8081",
114        )
115        .await
116        .unwrap();
117}

Source

pub fn service( self, name: &str, desc: &str, handlers: Vec<HandlerGeneric<T, H>>, ) -> Self

Register a service with additional handlers

Examples found in repository ?

examples/test.rs (line 105)

101async fn main() {
102    let state = "".to_string();
103
104    let server = AFast::<String, Header>::new(state)
105        .service("user", "User service", register! { get_user, get_id })
106        .middleware(auth);
107
108    server
109        .serve(
110            #[cfg(feature = "tcp")]
111            &"127.0.0.1:8080",
112            #[cfg(any(feature = "http", feature = "ws"))]
113            &"127.0.0.1:8081",
114        )
115        .await
116        .unwrap();
117}

Source

pub async fn serve<A: ToSocketAddrs>(&self, addr_http: A) -> Result<(), Error>

Start the server

Depending on feature flags, this will start TCP, HTTP, and/or WebSocket services.

§Arguments

addr_tcp - TCP listening address (only active if tcp feature enabled)
addr_http - HTTP/WebSocket listening address (only active if http or ws feature enabled)

§Returns

Result<(), Error>

Examples found in repository ?

examples/test.rs (lines 109-114)

101async fn main() {
102    let state = "".to_string();
103
104    let server = AFast::<String, Header>::new(state)
105        .service("user", "User service", register! { get_user, get_id })
106        .middleware(auth);
107
108    server
109        .serve(
110            #[cfg(feature = "tcp")]
111            &"127.0.0.1:8080",
112            #[cfg(any(feature = "http", feature = "ws"))]
113            &"127.0.0.1:8081",
114        )
115        .await
116        .unwrap();
117}