Trait OnResponseStreamBeginHandler 

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

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

Available on crate feature servers only.

A handler for when a stream begins (an “on connection” event), 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<bool, CatBridgeError>> + Send + 'static

Required Methods

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

Implementors

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

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

Available on crate features clients or servers only.

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

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

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

Available on crate features clients or servers only.

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

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

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

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send, T12: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send, T12: FromResponseStreamEvent<State> + Send, T13: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send, T12: FromResponseStreamEvent<State> + Send, T13: FromResponseStreamEvent<State> + Send, T14: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send, T12: FromResponseStreamEvent<State> + Send, T13: FromResponseStreamEvent<State> + Send, T14: FromResponseStreamEvent<State> + Send, T15: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

impl<UnderlyingFnType, FnFutureTy, OutputTy, State, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> OnResponseStreamBeginHandler<(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<bool, CatBridgeError>>, State: Clone + Send + Sync + 'static, T1: FromResponseStreamEvent<State> + Send, T2: FromResponseStreamEvent<State> + Send, T3: FromResponseStreamEvent<State> + Send, T4: FromResponseStreamEvent<State> + Send, T5: FromResponseStreamEvent<State> + Send, T6: FromResponseStreamEvent<State> + Send, T7: FromResponseStreamEvent<State> + Send, T8: FromResponseStreamEvent<State> + Send, T9: FromResponseStreamEvent<State> + Send, T10: FromResponseStreamEvent<State> + Send, T11: FromResponseStreamEvent<State> + Send, T12: FromResponseStreamEvent<State> + Send, T13: FromResponseStreamEvent<State> + Send, T14: FromResponseStreamEvent<State> + Send, T15: FromResponseStreamEvent<State> + Send, T16: FromResponseStreamEvent<State> + Send,

Available on crate features clients or servers only.

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

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

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

Available on crate features clients or servers only.

Allow any async function without arguments to be a handler.

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

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

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

Available on crate features clients or servers only.

Allow any async function with a single consuming argument.

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