Trait OnRequestStreamEndHandler 

pub trait OnRequestStreamEndHandler<ParamTy, State: Clone + Send + Sync + 'static> {
    type Future: Future<Output = Result<(), CatBridgeError>> + Send + 'static;

    // Required method
    fn call(self, event: RequestStreamEvent<State>) -> Self::Future;
}

Available on (crate features clients or servers) and crate feature clients only.

A stream ending/(on disconnect) handler, attempts to be an incredibly thin layer between a function, and the actual ending handler.

Implemented so we can implement for function that accepts any varying amount of args of types that implement from request parts.

ParamTy is kept to prevent generation of conflicting type implementations of this trait. It however is not actually needed by any of our code.

Required Associated Types

type Future: Future<Output = Result<(), CatBridgeError>> + Send + 'static

Required Methods

fn call(self, event: RequestStreamEvent<State>) -> Self::Future

Implementors

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1> OnRequestStreamEndHandler<(T1,), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2> OnRequestStreamEndHandler<(T1, T2), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3> OnRequestStreamEndHandler<(T1, T2, T3), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4> OnRequestStreamEndHandler<(T1, T2, T3, T4), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send, T12: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send, T12: FromRequestStreamEvent<State> + Send, T13: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send, T12: FromRequestStreamEvent<State> + Send, T13: FromRequestStreamEvent<State> + Send, T14: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send, T12: FromRequestStreamEvent<State> + Send, T13: FromRequestStreamEvent<State> + Send, T14: FromRequestStreamEvent<State> + Send, T15: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> OnRequestStreamEndHandler<(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = OutputTy> + Send, OutputTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromRequestStreamEvent<State> + Send, T2: FromRequestStreamEvent<State> + Send, T3: FromRequestStreamEvent<State> + Send, T4: FromRequestStreamEvent<State> + Send, T5: FromRequestStreamEvent<State> + Send, T6: FromRequestStreamEvent<State> + Send, T7: FromRequestStreamEvent<State> + Send, T8: FromRequestStreamEvent<State> + Send, T9: FromRequestStreamEvent<State> + Send, T10: FromRequestStreamEvent<State> + Send, T11: FromRequestStreamEvent<State> + Send, T12: FromRequestStreamEvent<State> + Send, T13: FromRequestStreamEvent<State> + Send, T14: FromRequestStreamEvent<State> + Send, T15: FromRequestStreamEvent<State> + Send, T16: FromRequestStreamEvent<State> + Send,

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, ResponseTy, State> OnRequestStreamEndHandler<(), State> for UnderlyingFnType

where UnderlyingFnType: FnOnce() -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = ResponseTy> + Send, ResponseTy: Into<Result<(), CatBridgeError>>, State: Clone + Send + Sync + 'static,

Allow any async function without arguments to be a handler

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>

impl<UnderlyingFnType, FnFutureTy, ResponseTy, State, ArgTy> OnRequestStreamEndHandler<ArgTy, State> for UnderlyingFnType

where UnderlyingFnType: FnOnce(ArgTy) -> FnFutureTy + Clone + Send + 'static, FnFutureTy: Future<Output = ResponseTy> + Send, ResponseTy: Into<Result<(), CatBridgeError>>, ArgTy: From<RequestStreamEvent<State>> + Send, State: Clone + Send + Sync + 'static,

Allow any async function with a single consuming argument.

type Future = Pin<Box<dyn Future<Output = Result<(), CatBridgeError>> + Send>>