cleanupStreams method

Future<void> cleanupStreams()

Closes all connected streams

Implementation

Future<void> cleanupStreams() async {
  for (var stream in openStreams.values) {
    stream.close();
  }
  openStreams.clear();
}