| |
self.service.listener_reacted(token, service_event, time);
|
| |
});
|
| |
} else {
|
| - |
let listener = self.deregister_listener(token).unwrap_or_else(|| panic!("listener with token {} has disappeared", token.0));
|
| + |
let listener = self.deregister_listener(token).unwrap_or_else(|| {
|
| + |
panic!("listener with token {} has disappeared", token.0)
|
| + |
});
|
| |
self.service
|
| |
.handle_error(Error::ListenerDisconnect(token, listener));
|
| |
deregistered.push(token);
|
| |
self.service.transport_reacted(token, service_event, time);
|
| |
});
|
| |
} else {
|
| - |
let transport = self.deregister_transport(token).unwrap_or_else(|| panic!("transport with token {} has disappeared", token.0));
|
| + |
let transport = self.deregister_transport(token).unwrap_or_else(|| {
|
| + |
panic!("transport with token {} has disappeared", token.0)
|
| + |
});
|
| |
self.service
|
| |
.handle_error(Error::TransportDisconnect(token, transport));
|
| |
deregistered.push(token);
|