Struct BidirWithFallback 

pub struct BidirWithFallback<Req, Resp>
where
    Req: Serialize + DeserializeOwned + Send + 'static,
    Resp: Serialize + DeserializeOwned + Send + 'static,
{ /* private fields */ }

Bidirectional channel with fallback when transport doesn’t support bidirectional

Wraps a BidirChannel and provides fallback values when bidirectional requests fail due to NotSupported error.

Implementations

impl<Req, Resp> BidirWithFallback<Req, Resp>

where Req: Serialize + DeserializeOwned + Send + 'static, Resp: Serialize + DeserializeOwned + Send + 'static,

pub fn new( channel: Arc<BidirChannel<Req, Resp>>, fallback: impl Fn(&Req) -> Resp + Send + Sync + 'static, ) -> Self

Create a new fallback wrapper with custom fallback function

pub async fn request(&self, req: Req) -> Resp

where Req: Clone,

Make a request, using fallback if bidirectional not supported

impl BidirWithFallback<StandardRequest, StandardResponse>

pub fn auto_confirm( channel: Arc<BidirChannel<StandardRequest, StandardResponse>>, ) -> Self

Create fallback that auto-confirms all requests