Translate 'Lwt_io.input_channel'

Author: Julow

bin/lwt_to_direct_style/ast_rewrite.ml

@@ -552,6 +552,7 @@ let rewrite_type ~backend ~state typ =
                  | "group_entry" ) as tname) ),
               params ) ->
               Some (mk_typ_constr ~params [ "Unix"; tname ])
+          | ("Lwt_io", "input_channel"), [] -> Some backend#type_in_channel
           | ("Lwt_io", "output_channel"), [] -> Some backend#type_out_channel
           | _ -> None)
   | _ -> None

bin/lwt_to_direct_style/concurrency_backend.ml

@@ -317,6 +317,7 @@ let eio ~eio_sw_as_fiber_var ~eio_env_as_fiber_var add_comment =
       mk_apply_simple [ "Eio"; "Buf_write"; "string" ] [ chan; str ]
 
     method io_close fd = mk_apply_simple [ "Eio"; "Resource"; "close" ] [ fd ]
+    method type_in_channel = mk_typ_constr [ "Eio"; "Buf_read"; "t" ]
     method type_out_channel = mk_typ_constr [ "Eio"; "Buf_write"; "t" ]
 
     method path_stat ~follow path =

test/lwt_to_direct_style/to_direct_style.t/run.t

@@ -228,42 +228,44 @@ Make a writable directory tree:
     Lwt_mutex.lock (line 136 column 9)
     Lwt_mutex.unlock (line 137 column 9)
     Lwt_mutex.with_lock (line 138 column 9)
-  lib/test_lwt_unix.ml: (41 occurrences)
+  lib/test_lwt_unix.ml: (43 occurrences)
     Lwt_io (line 7 column 8)
     Lwt.return (line 12 column 3)
     Lwt.let* (line 10 column 3)
     Lwt.let* (line 11 column 3)
-    Lwt.let* (line 29 column 3)
-    Lwt.let* (line 33 column 3)
+    Lwt.let* (line 30 column 3)
+    Lwt.let* (line 34 column 3)
     Lwt.Syntax (line 1 column 6)
     Lwt_io.Input (line 22 column 32)
     Lwt_io.Output (line 23 column 32)
     Lwt_io.input (line 7 column 28)
-    Lwt_io.input (line 29 column 36)
+    Lwt_io.input (line 30 column 36)
     Lwt_io.output (line 21 column 32)
-    Lwt_io.output (line 33 column 36)
-    Lwt_io.output_channel (line 25 column 9)
-    Lwt_io.close (line 30 column 3)
+    Lwt_io.output (line 34 column 36)
+    Lwt_io.input_channel (line 25 column 9)
+    Lwt_io.output_channel (line 26 column 9)
+    Lwt_io.close (line 31 column 3)
     Lwt_io.of_fd (line 7 column 16)
     Lwt_io.of_fd (line 21 column 13)
     Lwt_io.of_fd (line 22 column 13)
     Lwt_io.of_fd (line 23 column 13)
-    Lwt_io.read_line (line 26 column 15)
-    Lwt_io.read (line 38 column 15)
+    Lwt_io.read_line (line 27 column 15)
     Lwt_io.read (line 39 column 15)
     Lwt_io.read (line 40 column 15)
+    Lwt_io.read (line 41 column 15)
     Lwt_io.read_into (line 10 column 21)
     Lwt_io.read_into_exactly (line 11 column 13)
-    Lwt_io.flush (line 41 column 15)
+    Lwt_io.flush (line 42 column 15)
     Lwt_io.write (line 24 column 19)
-    Lwt_io.length (line 34 column 3)
-    Lwt_io.stdout (line 25 column 33)
-    Lwt_io.open_file (line 29 column 13)
-    Lwt_io.open_file (line 33 column 13)
+    Lwt_io.length (line 35 column 3)
+    Lwt_io.stdin (line 25 column 32)
+    Lwt_io.stdout (line 26 column 33)
+    Lwt_io.open_file (line 30 column 13)
+    Lwt_io.open_file (line 34 column 13)
     Lwt_unix.Timeout (line 14 column 9)
     Lwt_unix.of_unix_file_descr (line 6 column 8)
-    Lwt_unix.stat (line 36 column 16)
-    Lwt_unix.lstat (line 37 column 16)
+    Lwt_unix.stat (line 37 column 16)
+    Lwt_unix.lstat (line 38 column 16)
     Lwt_unix.sockaddr (line 15 column 9)
     Lwt_unix.ADDR_UNIX (line 15 column 29)
     Lwt_unix.ADDR_UNIX (line 17 column 6)
@@ -300,10 +302,11 @@ Make a writable directory tree:
     Lwt.Fail (line 147 column 5)
     Lwt.let* (line 163 column 21)
     Lwt.Fail (line 179 column 9)
-  Warning: lib/test_lwt_unix.ml: 3 occurrences have not been rewritten.
-    Lwt_io.stdout (line 25 column 33)
-    Lwt_io.read (line 39 column 15)
+  Warning: lib/test_lwt_unix.ml: 4 occurrences have not been rewritten.
+    Lwt_io.stdin (line 25 column 32)
+    Lwt_io.stdout (line 26 column 33)
     Lwt_io.read (line 40 column 15)
+    Lwt_io.read (line 41 column 15)
   Warning: lib/test.mli: 2 occurrences have not been rewritten.
     Lwt_mutex.t (line 2 column 10)
     Lwt_mutex.t (line 3 column 10)
@@ -749,6 +752,7 @@ Make a writable directory tree:
       (fun outbuf -> `Move_writing_code_here)
   
   let _f out_chan = Eio.Buf_write.string out_chan "str"
+  let _ : Eio.Buf_read.t = Lwt_io.stdin
   let _ : Eio.Buf_write.t = Lwt_io.stdout
   let _f chan = Eio.Buf_read.line chan
   

test/lwt_to_direct_style/to_direct_style.t/src/lib/test_lwt_unix.ml

@@ -22,6 +22,7 @@ let _f fd = Lwt_io.of_fd ~mode:Lwt_io.output fd
 let _f fd = Lwt_io.of_fd ~mode:Lwt_io.Input fd
 let _f fd = Lwt_io.of_fd ~mode:Lwt_io.Output fd
 let _f out_chan = Lwt_io.write out_chan "str"
+let _ : Lwt_io.input_channel = Lwt_io.stdin
 let _ : Lwt_io.output_channel = Lwt_io.stdout
 let _f chan = Lwt_io.read_line chan