cgp_dispatch/providers/with_handlers/
match_first_with_handlers.rs

1use core::marker::PhantomData;
2
3use cgp_core::prelude::*;
4use cgp_handler::{AsyncComputer, AsyncComputerComponent, Computer, ComputerComponent};
5
6use crate::DispatchMatchers;
7
8pub struct MatchFirstWithHandlers<Handlers>(pub PhantomData<Handlers>);
9
10#[cgp_provider]
11impl<Context, Code, Input, Args, Output, Remainder, Handlers> Computer<Context, Code, (Input, Args)>
12    for MatchFirstWithHandlers<Handlers>
13where
14    Input: HasExtractor,
15    DispatchMatchers<Handlers>: Computer<
16            Context,
17            Code,
18            (Input::Extractor, Args),
19            Output = Result<Output, (Remainder, Args)>,
20        >,
21    Remainder: FinalizeExtract,
22{
23    type Output = Output;
24
25    fn compute(context: &Context, code: PhantomData<Code>, (input, args): (Input, Args)) -> Output {
26        let res = DispatchMatchers::compute(context, code, (input.to_extractor(), args));
27        match res {
28            Ok(output) => output,
29            Err((remainder, _)) => remainder.finalize_extract(),
30        }
31    }
32}
33
34#[cgp_provider]
35impl<Context, Code, Input, Args, Output, Remainder, Handlers>
36    AsyncComputer<Context, Code, (Input, Args)> for MatchFirstWithHandlers<Handlers>
37where
38    Input: HasExtractor,
39    DispatchMatchers<Handlers>: AsyncComputer<
40            Context,
41            Code,
42            (Input::Extractor, Args),
43            Output = Result<Output, (Remainder, Args)>,
44        >,
45    Remainder: FinalizeExtract,
46{
47    type Output = Output;
48
49    async fn compute_async(
50        context: &Context,
51        code: PhantomData<Code>,
52        (input, args): (Input, Args),
53    ) -> Output {
54        let res =
55            DispatchMatchers::compute_async(context, code, (input.to_extractor(), args)).await;
56
57        match res {
58            Ok(output) => output,
59            Err((remainder, _)) => remainder.finalize_extract(),
60        }
61    }
62}
cgp_dispatch/providers/with_handlers/match_first_with_handlers.rs

cgp_dispatch/providers/with_handlers/
match_first_with_handlers.rs
