relay_binding

tirea_agentos_server::transport

Function relay_binding 

Source 
pub async fn relay_binding<UpMsg, DownMsg>(
    binding: TransportBinding<UpMsg, DownMsg>,
    cancel: RelayCancellation,
) -> Result<(), TransportError>
where
    UpMsg: Send + 'static,
    DownMsg: Send + 'static,
Expand description

Relay one bound session bidirectionally:

  • upstream.recv -> downstream.send
  • downstream.recv -> upstream.send