diff --git a/lib/src/collect.dart b/lib/src/collect.dart
index edb7c19..9aba764 100644
--- a/lib/src/collect.dart
+++ b/lib/src/collect.dart
@@ -51,10 +51,10 @@
       final options = const CompressionOptions(enabled: false);
       final socket = await WebSocket.connect('$uri', compression: options);
       final controller = StreamController<String>();
-      socket.listen(
-          (data) => controller.add(data as String),
-          onDone: () { controller.close(); service.dispose(); }
-      );
+      socket.listen((data) => controller.add(data as String), onDone: () {
+        controller.close();
+        service.dispose();
+      });
       service = VmService(
           controller.stream, (String message) => socket.add(message),
           log: StdoutLog(), disposeHandler: () => socket.close());
@@ -120,7 +120,9 @@
   final vm = await service.getVM();
   final futures = <Future>[];
   for (var isolateRef in vm.isolates) {
-    // Guard against sync as well as async errors
+    // Guard against sync as well as async errors: sync - when we are writing
+    // message to the socket, the socket might be closed; async - when we are
+    // waiting for the response, the socket again closes.
     futures.add(Future.sync(() async {
       final isolate = await service.getIsolate(isolateRef.id) as Isolate;
       if (isolate.pauseEvent.kind != EventKind.kResume) {
@@ -130,7 +132,7 @@
   }
   try {
     await Future.wait(futures);
-  } catch(e) {
+  } catch (_) {
     // Ignore resume isolate failures
   }
 }