async fn error(&self, flow: FlowId, error: TransportErrorCode) {
        if let TransportErrorCode::SenderErrorIndicated = error {
            let sender = {
                let send_map = self.peer_flows.transport.send_map.read().unwrap();
                send_map
                    .get(&self.node_id)
                    .expect("Self Node channel not setup")
                    .clone()
            };
            sender
                .send(TransportNotification::TransportError(
                    TransportError::TransportSendError(TransportFlowInfo {
                        peer_id: flow.peer_id,
                        flow_tag: flow.flow_tag,
                    }),
                ))
                .await
                .unwrap_or_else(|e| {
                    // Panic as we  will be blocking re-transmission requests at this point.
                    panic!("Failed to dispatch transport error {:?}", e)
                });
        }
    }
/// If there is a sender error, the method sends a transport error
/// notification message on the flow associated with the given flow ID.
If there is a sender error, the method sends a transport error
notification message on the flow associated with the given flow ID.
If there is a sender error the method sends a transport error notification message on the flow associated with the given flow ID .
async fn error(&self, flow: FlowId, error: TransportErrorCode) {
        if let TransportErrorCode::SenderErrorIndicated = error {
            let sender = {
                let send_map = self.peer_flows.transport.send_map.read().unwrap();
                send_map
                    .get(&self.node_id)
                    .expect("Self Node channel not setup")
                    .clone()
            };
            sender
                .send(TransportNotification::TransportError(
                    TransportError::TransportSendError(TransportFlowInfo {
                        peer_id: flow.peer_id,
                        flow_tag: flow.flow_tag,
                    }),
                ))
                .await
                .unwrap_or_else(|e| {
                    // Panic as we  will be blocking re-transmission requests at this point.
                    panic!("Failed to dispatch transport error {:?}", e)
                });
        }
    }
async fn error ( & self , flow : FlowId , error : TransportErrorCode ) { if let TransportErrorCode :: SenderErrorIndicated = error { let sender = { let send_map = self . peer_flows . transport . send_map . read ( ) . unwrap ( ) ; send_map . get ( & self . node_id ) . expect ( " " ) . clone ( ) } ; sender . send ( TransportNotification :: TransportError ( TransportError :: TransportSendError ( TransportFlowInfo { peer_id : flow . peer_id , flow_tag : flow . flow_tag , } ) , ) ) . await . unwrap_or_else ( | e | { // Panic as we  will be blocking re-transmission requests at this point. panic ! ( " " e ) } ) ; } }
If there is a sender error, the method sends a transport error
notification message on the flow associated with the given flow ID.
If there is a sender error the method sends a transport error notification message on the flow associated with the given flow ID .
&self
flow
FlowId
error
TransportErrorCode
&self
flow
FlowId
error
TransportErrorCode