feat: add AsyncUnref ops (#3721)

This is in order to support features like signal handlers, which
shouldn't prevent the program from exiting.

1 files changed, 8 insertions, 0 deletions

diff --git a/cli/state.rs b/cli/state.rs
index 02c258280..c07b3d5d0 100644
--- a/cli/state.rs
+++ b/cli/state.rs
@@ -110,6 +110,14 @@ impl ThreadSafeState {
           });
           Op::Async(result_fut.boxed())
         }
+        Op::AsyncUnref(fut) => {
+          let state = state.clone();
+          let result_fut = fut.map_ok(move |buf: Buf| {
+            state.metrics_op_completed(buf.len());
+            buf
+          });
+          Op::AsyncUnref(result_fut.boxed())
+        }
       }
     }
   }