closeStales method

Future<void> closeStales(
  1. Map<String, RSocket> staleRSockets
)

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();
  });
}