diff --git a/bin/lwt_to_direct_style/ast_rewrite.ml b/bin/lwt_to_direct_style/ast_rewrite.ml
index 520c610..9887cc3 100644
--- a/bin/lwt_to_direct_style/ast_rewrite.ml
+++ b/bin/lwt_to_direct_style/ast_rewrite.ml
@@ -149,10 +149,10 @@ let lwt_io_mode_of_ast ~state mode =
         | _ -> None)
   | _ -> None
 
-let lwt_io_of_fd ~backend ~state ~mode fd =
+let lwt_io_open ~backend ~state ~mode src =
   match lwt_io_mode_of_ast ~state mode with
-  | Some `Input -> Some (backend#input_io_of_fd fd)
-  | Some `Output -> Some (backend#output_io_of_fd fd)
+  | Some `Input -> Some (backend#input_io src)
+  | Some `Output -> Some (backend#output_io src)
   | None ->
       add_comment state
         "Couldn't translate this call to [Lwt_io.of_fd] because the [~mode] \
@@ -160,6 +160,11 @@ let lwt_io_of_fd ~backend ~state ~mode fd =
          [Lwt_io.output].";
       None
 
+let lwt_io_read ~backend ~state:_ count in_chan =
+  match count with
+  | Some count_arg -> backend#io_read_string_count in_chan count_arg
+  | None -> Some (backend#io_read_all in_chan)
+
 let mk_cstr c = Some (mk_constr_exp [ c ])
 
 (* Rewrite calls to functions from the [Lwt] module. See [rewrite_apply] for
@@ -322,10 +327,9 @@ let rewrite_apply ~backend ~state full_ident args =
       take @@ fun d ->
       take @@ fun f -> return (Some (backend#with_timeout d f))
   | "Lwt_unix", "of_unix_file_descr" ->
-      take @@ fun fd ->
       take_lblopt "blocking" @@ fun blocking ->
-      ignore_lblarg "set_flags"
-      @@ return (Some (backend#of_unix_file_descr ?blocking fd))
+      ignore_lblarg "set_flags" @@ take
+      @@ fun fd -> return (Some (backend#of_unix_file_descr ?blocking fd))
   | "Lwt_unix", "close" -> take @@ fun fd -> return (Some (backend#fd_close fd))
   (* [Lwt_unix] contains functions exactly equivalent to functions of the same
      name in [Unix]. *)
@@ -334,6 +338,10 @@ let rewrite_apply ~backend ~state full_ident args =
         "This call to [Unix.%s] was [Lwt_unix.%s] before the rewrite." fname
         fname;
       transparent [ "Unix"; fname ]
+  | "Lwt_unix", "stat" ->
+      take @@ fun path -> return (Some (backend#path_stat ~follow:true path))
+  | "Lwt_unix", "lstat" ->
+      take @@ fun path -> return (Some (backend#path_stat ~follow:false path))
   | "Lwt_condition", "create" ->
       take @@ fun _unit -> return (Some (backend#condition_create ()))
   | "Lwt_condition", "wait" ->
@@ -359,10 +367,23 @@ let rewrite_apply ~backend ~state full_ident args =
       @@ ignore_lblarg ~cmt:"Will behave as if it was [true]." "close"
       @@ take_lbl "mode"
       @@ fun mode ->
-      take @@ fun fd -> return (lwt_io_of_fd ~backend ~state ~mode fd)
+      take @@ fun fd -> return (lwt_io_open ~backend ~state ~mode (`Of_fd fd))
+  | "Lwt_io", "open_file" ->
+      ignore_lblarg "buffer" @@ ignore_lblarg "flags" @@ ignore_lblarg "perm"
+      @@ take_lbl "mode"
+      @@ fun mode ->
+      take @@ fun fname ->
+      return (lwt_io_open ~backend ~state ~mode (`Fname fname))
+  | "Lwt_io", "read_line" ->
+      take @@ fun in_chan -> return (Some (backend#io_read_line in_chan))
+  | "Lwt_io", "read" ->
+      take_lblopt "count" @@ fun count ->
+      take @@ fun in_chan -> return (lwt_io_read ~backend ~state count in_chan)
   | "Lwt_io", "write" ->
       take @@ fun chan ->
       take @@ fun str -> return (Some (backend#io_write_str chan str))
+  | "Lwt_io", "length" -> take @@ fun fd -> return (Some (backend#io_length fd))
+  | "Lwt_io", "close" -> take @@ fun fd -> return (Some (backend#io_close fd))
   | "Lwt_main", "run" ->
       take @@ fun promise -> return (Some (backend#main_run promise))
   | _ -> return None
diff --git a/bin/lwt_to_direct_style/concurrency_backend.ml b/bin/lwt_to_direct_style/concurrency_backend.ml
index eece57d..4e32f7c 100644
--- a/bin/lwt_to_direct_style/concurrency_backend.ml
+++ b/bin/lwt_to_direct_style/concurrency_backend.ml
@@ -12,7 +12,11 @@ let eio ~eio_sw_as_fiber_var ~eio_env_as_fiber_var add_comment =
   in
   let fiber_ident = eio_std_ident "Fiber"
   and promise_ident = eio_std_ident "Promise"
-  and switch_ident = eio_std_ident "Switch" in
+  and switch_ident = eio_std_ident "Switch"
+  and std_ident i =
+    used_eio_std := true;
+    [ i ]
+  in
   let add_comment fmt = Format.kasprintf add_comment fmt in
   let add_comment_dropped_exp ~label exp =
     add_comment "Dropped expression (%s): [%s]." label
@@ -47,6 +51,39 @@ let eio ~eio_sw_as_fiber_var ~eio_env_as_fiber_var add_comment =
     in
     Exp.send env_exp (mk_loc field)
   in
+  let buf_read_of_flow flow =
+    mk_apply_ident
+      [ "Eio"; "Buf_read"; "of_flow" ]
+      [
+        (Labelled (mk_loc "max_size"), mk_const_int "1_000_000"); (Nolabel, flow);
+      ]
+  in
+  let buf_write_of_flow flow =
+    add_comment
+      "Write operations to buffered IO should be moved inside [with_flow].";
+    mk_apply_simple
+      [ "Eio"; "Buf_write"; "with_flow" ]
+      [
+        flow;
+        mk_fun ~arg_name:"outbuf" (fun _outbuf ->
+            mk_variant_exp "Move_writing_code_here");
+      ]
+  in
+  let import_socket_stream ~r_or_w fd =
+    (* Used by [input_io] and [output_io]. *)
+    Exp.constraint_
+      (mk_apply_ident
+         [ "Eio_unix"; "Net"; "import_socket_stream" ]
+         [
+           get_current_switch_arg ();
+           (Labelled (mk_loc "close_unix"), mk_constr_exp [ "true" ]);
+           (Nolabel, fd);
+         ])
+      (mk_typ_constr
+         ~params:
+           [ mk_poly_variant [ (r_or_w, []); ("Flow", []); ("Close", []) ] ]
+         (std_ident "r"))
+  in
   object
     method both ~left ~right =
       mk_apply_simple (fiber_ident "pair") [ left; right ]
@@ -150,31 +187,51 @@ let eio ~eio_sw_as_fiber_var ~eio_env_as_fiber_var add_comment =
 
     method direct_style_type param = param
 
-    method of_unix_file_descr ?blocking fd =
-      let blocking_arg =
-        let lbl = mk_loc "blocking" in
-        match blocking with
-        | Some (expr, `Lbl) -> [ (Labelled lbl, expr) ]
-        | Some (expr, `Opt) -> [ (Optional lbl, expr) ]
-        | None -> []
-      in
-      mk_apply_ident
-        [ "Eio_unix"; "Fd"; "of_unix" ]
-        ([ get_current_switch_arg () ]
-        @ blocking_arg
-        @ [
-            (Labelled (mk_loc "close_unix"), mk_constr_exp [ "true" ]);
-            (Nolabel, fd);
-          ])
+    method of_unix_file_descr ?blocking:_ fd =
+      (* TODO: We don't use [Eio_unix.Fd.t] because there is no conversion to [Flow.sink]. *)
+      (* let blocking_arg = *)
+      (*   let lbl = mk_loc "blocking" in *)
+      (*   match blocking with *)
+      (*   | Some (expr, `Lbl) -> [ (Labelled lbl, expr) ] *)
+      (*   | Some (expr, `Opt) -> [ (Optional lbl, expr) ] *)
+      (*   | None -> [] *)
+      (* in *)
+      (* mk_apply_ident *)
+      (*   [ "Eio_unix"; "Fd"; "of_unix" ] *)
+      (*   ([ get_current_switch_arg () ] *)
+      (*   @ blocking_arg *)
+      (*   @ [ *)
+      (*       (Labelled (mk_loc "close_unix"), mk_constr_exp [ "true" ]); *)
+      (*       (Nolabel, fd); *)
+      (*     ]) *)
+      fd
 
     method io_read input buffer buf_offset buf_len =
       add_comment "[%s] should be a [Cstruct.t]."
         (Ocamlformat_utils.format_expression buffer);
+      add_comment
+        "[Eio.Flow.single_read] operates on a [Flow.source] but [%s] is likely \
+         of type [Eio.Buf_read.t]. Rewrite this code to use [Buf_read] (which \
+         contains an internal buffer) or change the call to \
+         [Eio.Buf_read.of_flow] used to create the buffer."
+        (Ocamlformat_utils.format_expression input);
       add_comment_dropped_exp ~label:"buffer offset" buf_offset;
       add_comment_dropped_exp ~label:"buffer length" buf_len;
       mk_apply_simple [ "Eio"; "Flow"; "single_read" ] [ input; buffer ]
 
-    method fd_close fd = mk_apply_simple [ "Eio_unix"; "Fd" ] [ fd ]
+    method io_read_all input =
+      mk_apply_simple [ "Eio"; "Buf_read"; "take_all" ] [ input ]
+
+    method io_read_string_count _input _count_arg =
+      add_comment
+        "Eio doesn't have a direct equivalent of [Lwt_io.read ~count]. Rewrite \
+         the code using [Eio.Buf_read]'s lower level API or switch to \
+         unbuffered IO.";
+      None
+
+    method fd_close fd =
+      (* TODO: See [of_unix_file_descr]. mk_apply_simple [ "Eio_unix"; "Fd" ] [ fd ] *)
+      mk_apply_simple [ "Unix"; "close" ] [ fd ]
 
     method main_run promise =
       let with_binding var_ident x body =
@@ -209,29 +266,56 @@ let eio ~eio_sw_as_fiber_var ~eio_env_as_fiber_var add_comment =
               wrap_env_fiber_var env (wrap_sw_fiber_var promise));
         ]
 
-    method input_io_of_fd fd =
-      Exp.constraint_
-        (mk_apply_simple [ "Eio_unix"; "Net"; "import_socket_stream" ] [ fd ])
-        (mk_typ_constr
-           ~params:
-             [ mk_poly_variant [ ("R", []); ("Flow", []); ("Close", []) ] ]
-           [ "Std"; "r" ])
-
-    method output_io_of_fd fd =
-      add_comment
-        "This creates a closeable [Flow.sink] resource but write operations \
-         are rewritten to calls to [Buf_write].\n\
-        \        You might want to use [Buf_write.with_flow sink (fun \
-         buf_write -> ...)].";
-      Exp.constraint_
-        (mk_apply_simple [ "Eio_unix"; "Net"; "import_socket_stream" ] [ fd ])
-        (mk_typ_constr
-           ~params:
-             [ mk_poly_variant [ ("W", []); ("Flow", []); ("Close", []) ] ]
-           [ "Std"; "r" ])
+    method input_io =
+      function
+      | `Of_fd fd -> buf_read_of_flow (import_socket_stream ~r_or_w:"R" fd)
+      | `Fname fname ->
+          buf_read_of_flow
+          @@ mk_apply_ident
+               [ "Eio"; "Path"; "open_in" ]
+               [
+                 get_current_switch_arg ();
+                 ( Nolabel,
+                   mk_apply_simple [ "Eio"; "Path"; "/" ] [ env "cwd"; fname ]
+                 );
+               ]
+
+    method output_io =
+      function
+      | `Of_fd fd -> buf_write_of_flow (import_socket_stream ~r_or_w:"W" fd)
+      | `Fname fname ->
+          add_comment
+            "[flags] and [perm] arguments were dropped. The [~create] was \
+             added by default and might not match the previous flags. Use \
+             [~append:true] for [O_APPEND].";
+          buf_write_of_flow
+          @@ mk_apply_ident
+               [ "Eio"; "Path"; "open_out" ]
+               [
+                 get_current_switch_arg ();
+                 ( Labelled (mk_loc "create"),
+                   mk_variant_exp ~arg:(mk_const_int "0o666") "If_missing" );
+                 ( Nolabel,
+                   mk_apply_simple [ "Eio"; "Path"; "/" ] [ env "cwd"; fname ]
+                 );
+               ]
+
+    method io_read_line chan =
+      mk_apply_simple [ "Eio"; "Buf_read"; "line" ] [ chan ]
+
+    (* This is of type [Optint.Int63.t] instead of [int] with Lwt. *)
+    method io_length fd = mk_apply_simple [ "Eio"; "File"; "size" ] [ fd ]
 
     method io_write_str chan str =
       mk_apply_simple [ "Eio"; "Buf_write"; "string" ] [ chan; str ]
 
+    method io_close fd = mk_apply_simple [ "Eio"; "Resource"; "close" ] [ fd ]
     method type_out_channel = mk_typ_constr [ "Eio"; "Buf_write"; "t" ]
+
+    method path_stat ~follow path =
+      mk_apply_ident [ "Eio"; "Path"; "stat" ]
+        [
+          (Labelled (mk_loc "follow"), mk_constr_of_bool follow);
+          (Nolabel, mk_apply_simple [ "Eio"; "Path"; "/" ] [ env "cwd"; path ]);
+        ]
   end
diff --git a/lib/ocamlformat_utils/ast_utils.ml b/lib/ocamlformat_utils/ast_utils.ml
index 9e6256d..14ce34e 100644
--- a/lib/ocamlformat_utils/ast_utils.ml
+++ b/lib/ocamlformat_utils/ast_utils.ml
@@ -65,6 +65,8 @@ let mk_poly_variant ?(open_ = false) ?labels ?(inherit_ = []) vars =
   let constrs = List.map mk_rtag vars @ List.map mk_inherit inherit_ in
   Typ.variant constrs flag labels
 
+let mk_constr_of_bool b = mk_constr_exp [ (if b then "true" else "false") ]
+
 (* Exp *)
 
 let mk_const_string s = Exp.constant (Const.string s)
diff --git a/test/lwt_to_direct_style/eio-switch.t/run.t b/test/lwt_to_direct_style/eio-switch.t/run.t
index 1c56e35..198d2d2 100644
--- a/test/lwt_to_direct_style/eio-switch.t/run.t
+++ b/test/lwt_to_direct_style/eio-switch.t/run.t
@@ -5,11 +5,7 @@ Make a writable directory tree:
   $ dune build @ocaml-index
   $ lwt-to-direct-style --migrate --eio-sw-as-fiber-var Fiber_var.sw --eio-env-as-fiber-var Fiber_var.env
   Formatted 1 files
-  Warning: main.ml: 5 occurrences have not been rewritten.
-    Lwt_io.open_file (line 8 column 13)
-    Lwt_io.input (line 8 column 36)
-    Lwt_io.close (line 9 column 3)
-    Lwt_io.read (line 15 column 12)
+  Warning: main.ml: 1 occurrences have not been rewritten.
     Lwt_io.printf (line 16 column 3)
 
   $ cat main.ml
@@ -22,25 +18,27 @@ Make a writable directory tree:
       (Stdlib.Option.get (Fiber.get Fiber_var.env))#mono_clock 1.0 (fun () -> 42)
   
   let _f fname =
-    let fd = Lwt_io.open_file ~mode:Lwt_io.input fname in
-    Lwt_io.close fd
+    let fd =
+      Eio.Buf_read.of_flow ~max_size:1_000_000
+        (Eio.Path.open_in
+           ~sw:(Stdlib.Option.get (Fiber.get Fiber_var.sw))
+           (Eio.Path.( / ) (Stdlib.Option.get (Fiber.get Fiber_var.env))#cwd fname))
+    in
+    Eio.Resource.close fd
   
   let main () =
     Fiber.fork
       ~sw:(Stdlib.Option.get (Fiber.get Fiber_var.sw))
       (fun () -> async_process 1);
-    let fd =
-     fun ?blocking:x1 ?set_flags:x2 ->
-      Eio_unix.Fd.of_unix
-        ~sw:(Stdlib.Option.get (Fiber.get Fiber_var.sw))
-        ?blocking:x1 ~close_unix:true
-        (* TODO: lwt-to-direct-style: Labelled argument ?set_flags was dropped. *)
-        Unix.stdin
-    in
+    let fd = Unix.stdin in
     let in_chan =
-      (Eio_unix.Net.import_socket_stream fd : [ `R | `Flow | `Close ] Std.r)
+      Eio.Buf_read.of_flow ~max_size:1_000_000
+        (Eio_unix.Net.import_socket_stream
+           ~sw:(Stdlib.Option.get (Fiber.get Fiber_var.sw))
+           ~close_unix:true fd
+          : [ `R | `Flow | `Close ] r)
     in
-    let s = Lwt_io.read in_chan in
+    let s = Eio.Buf_read.take_all in_chan in
     Lwt_io.printf "%s" s
   
   let () =
diff --git a/test/lwt_to_direct_style/to_direct_style.t/run.t b/test/lwt_to_direct_style/to_direct_style.t/run.t
index 1ec42d3..ac72ec5 100644
--- a/test/lwt_to_direct_style/to_direct_style.t/run.t
+++ b/test/lwt_to_direct_style/to_direct_style.t/run.t
@@ -228,25 +228,39 @@ 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: (24 occurrences)
+  lib/test_lwt_unix.ml: (38 occurrences)
     Lwt_io (line 7 column 8)
     Lwt.return (line 11 column 3)
     Lwt.let* (line 10 column 3)
+    Lwt.let* (line 31 column 3)
+    Lwt.let* (line 35 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 31 column 36)
     Lwt_io.output (line 21 column 32)
+    Lwt_io.output (line 35 column 36)
     Lwt_io.output_channel (line 26 column 9)
+    Lwt_io.close (line 32 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 28 column 15)
+    Lwt_io.read (line 41 column 15)
+    Lwt_io.read (line 42 column 15)
+    Lwt_io.read (line 43 column 15)
     Lwt_io.read_into (line 10 column 19)
     Lwt_io.write (line 24 column 19)
+    Lwt_io.length (line 36 column 3)
     Lwt_io.stdout (line 26 column 33)
+    Lwt_io.open_file (line 31 column 13)
+    Lwt_io.open_file (line 35 column 13)
     Lwt_unix.Timeout (line 13 column 9)
     Lwt_unix.of_unix_file_descr (line 6 column 8)
+    Lwt_unix.stat (line 38 column 16)
+    Lwt_unix.lstat (line 39 column 16)
     Lwt_unix.sockaddr (line 14 column 9)
     Lwt_unix.ADDR_UNIX (line 14 column 29)
     Lwt_unix.ADDR_UNIX (line 16 column 6)
@@ -283,8 +297,10 @@ 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: 1 occurrences have not been rewritten.
+  Warning: lib/test_lwt_unix.ml: 3 occurrences have not been rewritten.
     Lwt_io.stdout (line 26 column 33)
+    Lwt_io.read (line 42 column 15)
+    Lwt_io.read (line 43 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)
@@ -662,22 +678,23 @@ Make a writable directory tree:
   module M : sig end
 
   $ cat lib/test_lwt_unix.ml
+  open Eio.Std
+  
   let _f fname =
     let inp =
-      (fun ?blocking:x1 ?set_flags:x2 ->
-        Eio_unix.Fd.of_unix ~sw ?blocking:x1 ~close_unix:true
-          (Unix
-           (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
-           (* TODO: lwt-to-direct-style: Labelled argument ?set_flags was dropped. *).(
-             openfile fname [ O_RDWR; O_NONBLOCK; O_APPEND ])
-             0o660))
-      |> fun x1 ->
-      (Eio_unix.Net.import_socket_stream x1 : [ `R | `Flow | `Close ] Std.r)
+      Unix.(openfile fname [ O_RDWR; O_NONBLOCK; O_APPEND ]) 0o660
+      |>
+      (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+      fun x1 ->
+      Eio.Buf_read.of_flow ~max_size:1_000_000
+        (Eio_unix.Net.import_socket_stream ~sw ~close_unix:true x1
+          : [ `R | `Flow | `Close ] r)
     in
     let buf = Bytes.create 1024 in
     let _n : int =
       Eio.Flow.single_read
         (* TODO: lwt-to-direct-style: [buf] should be a [Cstruct.t]. *)
+        (* TODO: lwt-to-direct-style: [Eio.Flow.single_read] operates on a [Flow.source] but [inp] is likely of type [Eio.Buf_read.t]. Rewrite this code to use [Buf_read] (which contains an internal buffer) or change the call to [Eio.Buf_read.of_flow] used to create the buffer. *)
         (* TODO: lwt-to-direct-style: Dropped expression (buffer offset): [0]. *)
         (* TODO: lwt-to-direct-style: Dropped expression (buffer length): [1024]. *)
         inp buf
@@ -696,21 +713,81 @@ Make a writable directory tree:
     Unix.getaddrinfo
   
   let _f fd =
-    (Eio_unix.Net.import_socket_stream
-       (* TODO: lwt-to-direct-style: This creates a closeable [Flow.sink] resource but write operations are rewritten to calls to [Buf_write].
-          You might want to use [Buf_write.with_flow sink (fun buf_write -> ...)]. *)
-       fd
-      : [ `W | `Flow | `Close ] Std.r)
+    Eio.Buf_write.with_flow
+      (Eio_unix.Net.import_socket_stream ~sw ~close_unix:true
+         (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+         (* TODO: lwt-to-direct-style: Write operations to buffered IO should be moved inside [with_flow]. *)
+         fd
+        : [ `W | `Flow | `Close ] r)
+      (fun outbuf -> `Move_writing_code_here)
   
   let _f fd =
-    (Eio_unix.Net.import_socket_stream fd : [ `R | `Flow | `Close ] Std.r)
+    Eio.Buf_read.of_flow ~max_size:1_000_000
+      (Eio_unix.Net.import_socket_stream ~sw ~close_unix:true
+         (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+         fd
+        : [ `R | `Flow | `Close ] r)
   
   let _f fd =
-    (Eio_unix.Net.import_socket_stream
-       (* TODO: lwt-to-direct-style: This creates a closeable [Flow.sink] resource but write operations are rewritten to calls to [Buf_write].
-          You might want to use [Buf_write.with_flow sink (fun buf_write -> ...)]. *)
-       fd
-      : [ `W | `Flow | `Close ] Std.r)
+    Eio.Buf_write.with_flow
+      (Eio_unix.Net.import_socket_stream ~sw ~close_unix:true
+         (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+         (* TODO: lwt-to-direct-style: Write operations to buffered IO should be moved inside [with_flow]. *)
+         fd
+        : [ `W | `Flow | `Close ] r)
+      (fun outbuf -> `Move_writing_code_here)
   
   let _f out_chan = Eio.Buf_write.string out_chan "str"
   let _ : Eio.Buf_write.t = Lwt_io.stdout
+  let _f chan = Eio.Buf_read.line chan
+  
+  let _f fname =
+    let fd =
+      Eio.Buf_read.of_flow ~max_size:1_000_000
+        (Eio.Path.open_in ~sw
+           (Eio.Path.( / ) env#cwd
+              (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+              (* TODO: lwt-to-direct-style: [env] must be propagated from the main loop *)
+              fname))
+    in
+    Eio.Resource.close fd
+  
+  let _f fname =
+    let fd =
+      Eio.Buf_write.with_flow
+        (Eio.Path.open_out ~sw ~create:(`If_missing 0o666)
+           (Eio.Path.( / ) env#cwd
+              (* TODO: lwt-to-direct-style: [sw] (of type Switch.t) must be propagated here. *)
+              (* TODO: lwt-to-direct-style: [flags] and [perm] arguments were dropped. The [~create] was added by default and might not match the previous flags. Use [~append:true] for [O_APPEND]. *)
+              (* TODO: lwt-to-direct-style: [env] must be propagated from the main loop *)
+              (* TODO: lwt-to-direct-style: Write operations to buffered IO should be moved inside [with_flow]. *)
+              fname))
+        (fun outbuf -> `Move_writing_code_here)
+    in
+    Eio.File.size fd
+  
+  let _f fname =
+    Eio.Path.stat ~follow:true
+      (Eio.Path.( / ) env#cwd
+         (* TODO: lwt-to-direct-style: [env] must be propagated from the main loop *)
+         fname)
+  
+  let _f fname =
+    Eio.Path.stat ~follow:false
+      (Eio.Path.( / ) env#cwd
+         (* TODO: lwt-to-direct-style: [env] must be propagated from the main loop *)
+         fname)
+  
+  let _f chan = Eio.Buf_read.take_all chan
+  
+  let _f chan =
+    Lwt_io.read
+    (* TODO: lwt-to-direct-style: Eio doesn't have a direct equivalent of [Lwt_io.read ~count]. Rewrite the code using [Eio.Buf_read]'s lower level API or switch to unbuffered IO. *)
+    (* TODO: lwt-to-direct-style: Eio doesn't have a direct equivalent of [Lwt_io.read ~count]. Rewrite the code using [Eio.Buf_read]'s lower level API or switch to unbuffered IO. *)
+      ~count:42 chan
+  
+  let _f chan =
+    Lwt_io.read
+    (* TODO: lwt-to-direct-style: Eio doesn't have a direct equivalent of [Lwt_io.read ~count]. Rewrite the code using [Eio.Buf_read]'s lower level API or switch to unbuffered IO. *)
+    (* TODO: lwt-to-direct-style: Eio doesn't have a direct equivalent of [Lwt_io.read ~count]. Rewrite the code using [Eio.Buf_read]'s lower level API or switch to unbuffered IO. *)
+      ?count:(Some 42) chan
diff --git a/test/lwt_to_direct_style/to_direct_style.t/src/lib/test_lwt_unix.ml b/test/lwt_to_direct_style/to_direct_style.t/src/lib/test_lwt_unix.ml
index a6c9bc9..d2759de 100644
--- a/test/lwt_to_direct_style/to_direct_style.t/src/lib/test_lwt_unix.ml
+++ b/test/lwt_to_direct_style/to_direct_style.t/src/lib/test_lwt_unix.ml
@@ -24,3 +24,20 @@ 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.output_channel = Lwt_io.stdout
+
+let _f chan = Lwt_io.read_line chan
+
+let _f fname =
+  let* fd = Lwt_io.open_file ~mode:Lwt_io.input fname in
+  Lwt_io.close fd
+
+let _f fname =
+  let* fd = Lwt_io.open_file ~mode:Lwt_io.output fname in
+  Lwt_io.length fd
+
+let _f fname = Lwt_unix.stat fname
+let _f fname = Lwt_unix.lstat fname
+
+let _f chan = Lwt_io.read chan
+let _f chan = Lwt_io.read ~count:42 chan
+let _f chan = Lwt_io.read ?count:(Some 42) chan