closeStales method
Implementation
Future<void> closeStales(Map<String, RSocket> staleRSockets) async {
await new Future.delayed(const Duration(seconds: 15));
staleRSockets.forEach((url, rsocket) {
print('Close RSocket: ${url}');
rsocket.close();
});
}