File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
io/zenoh-transport/src/unicast/lowlatency Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -122,17 +122,17 @@ impl TransportUnicastLowlatency {
122
122
// Delete the transport on the manager
123
123
let _ = self . manager . del_transport_unicast ( & self . config . zid ) . await ;
124
124
125
- if let Some ( val) = zasyncwrite ! ( self . link) . as_ref ( ) {
126
- let _ = val. close ( Some ( close:: reason:: GENERIC ) ) . await ;
127
- }
128
-
129
125
// Close and drop the link
130
126
self . token . cancel ( ) ;
131
127
self . tracker . close ( ) ;
132
128
self . tracker . wait ( ) . await ;
133
129
// self.stop_keepalive().await;
134
130
// self.stop_rx().await;
135
131
132
+ if let Some ( val) = zasyncwrite ! ( self . link) . as_ref ( ) {
133
+ let _ = val. close ( Some ( close:: reason:: GENERIC ) ) . await ;
134
+ }
135
+
136
136
// Notify the callback that we have closed the transport
137
137
if let Some ( cb) = callback. as_ref ( ) {
138
138
cb. closed ( ) ;
You can’t perform that action at this time.
0 commit comments