Port async examples to Command.Param

relates to #113 Signed-off-by: Anurag Soni <[email protected]>
inhabitedtype · Mar 28, 2019 · c90801c · c90801c
1 parent 46b9da7
commit c90801c
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 33 deletions.
diff --git a/benchmarks/wrk_async_benchmark.ml b/benchmarks/wrk_async_benchmark.ml
@@ -40,13 +40,14 @@ let main port max_accepts_per_batch () =
   Deferred.never ()
 
 let () =
-  Command.async_spec
+  Command.async
     ~summary:"Start a hello world Async server"
-    Command.Spec.(empty +>
-      flag "-p" (optional_with_default 8080 int)
-        ~doc:"int Source port to listen on"
-      +>
-      flag "-a" (optional_with_default 1 int)
-        ~doc:"int Maximum accepts per batch"
-    ) main
+    Command.Param.(
+      map (both
+          (flag "-p" (optional_with_default 8080 int)
+            ~doc:"int Source port to listen on")
+          (flag "-a" (optional_with_default 1 int)
+            ~doc:"int Maximum accepts per batch"))
+        ~f:(fun (port, accepts) ->
+              (fun () -> main port accepts ())))
   |> Command.run
diff --git a/examples/async/async_echo_post.ml b/examples/async/async_echo_post.ml
@@ -50,13 +50,14 @@ let main port max_accepts_per_batch () =
   Deferred.never ()
 
 let () =
-  Command.async_spec
+  Command.async
     ~summary:"Start a hello world Async server"
-    Command.Spec.(empty +>
-      flag "-p" (optional_with_default 8080 int)
-        ~doc:"int Source port to listen on"
-      +>
-      flag "-a" (optional_with_default 1 int)
-        ~doc:"int Maximum accepts per batch"
-    ) main
+    Command.Param.(
+      map (both
+          (flag "-p" (optional_with_default 8080 int)
+            ~doc:"int Source port to listen on")
+          (flag "-a" (optional_with_default 1 int)
+            ~doc:"int Maximum accepts per batch"))
+        ~f:(fun (port, accepts) ->
+              (fun () -> main port accepts ())))
   |> Command.run
diff --git a/examples/async/async_get.ml b/examples/async/async_get.ml
@@ -1,4 +1,4 @@
-open Core
+open! Core
 open Async
 
 open Httpaf
@@ -37,13 +37,14 @@ let main port host () =
 ;;
 
 let () =
-  Command.async_spec
+  Command.async
     ~summary:"Start a hello world Async client"
-    Command.Spec.(empty +>
-      flag "-p" (optional_with_default 80 int)
-        ~doc:"int destination port"
-      +>
-      flag "-h" (required string)
-        ~doc:"string destination host"
-    ) main
+    Command.Param.(
+      map (both
+          (flag "-p" (optional_with_default 80 int)
+            ~doc:"int destination port")
+          (flag "-h" (required string)
+            ~doc:"string destination host"))
+        ~f:(fun (port, host) ->
+              (fun () -> main port host ())))
   |> Command.run
diff --git a/examples/async/async_post.ml b/examples/async/async_post.ml
@@ -52,13 +52,14 @@ let main port host () =
 ;;
 
 let () =
-  Command.async_spec
+  Command.async
     ~summary:"Start a hello world Async client"
-    Command.Spec.(empty +>
-      flag "-p" (optional_with_default 80 int)
-        ~doc:"int destination port"
-      +>
-      flag "-a" (required string)
-        ~doc:"string destination ip"
-    ) main
+    Command.Param.(
+      map (both
+          (flag "-p" (optional_with_default 80 int)
+            ~doc:"int destination port")
+          (flag "-h" (required string)
+            ~doc:"string destination host"))
+        ~f:(fun (port, host) ->
+              (fun () -> main port host ())))
   |> Command.run