fusen-rs 0.8.11

RPC framework for service registration and discovery through API exposure, compatible with Dubbo3 protocol, intertunable with Java projects
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use fusen_internal_common::BoxFuture;

use crate::{
    error::FusenError,
    filter::{FusenFilter, ProceedingJoinPoint},
    protocol::fusen::context::FusenContext,
};

#[allow(async_fn_in_trait)]
pub trait Aspect {
    async fn aroud(&self, join_point: ProceedingJoinPoint) -> Result<FusenContext, FusenError>;
}

pub struct DefaultAspect;

impl FusenFilter for DefaultAspect {
    fn call(&self, join_point: ProceedingJoinPoint) -> BoxFuture<Result<FusenContext, FusenError>> {
        Box::pin(async move { join_point.proceed().await })
    }
}