Skip to content

Commit 888bc73

Browse files
committed
Use Luv.Pipe.pipe
1 parent c5cbd26 commit 888bc73

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

lib_eio_luv/eio_luv.ml

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1157,9 +1157,7 @@ let rec run : type a. (_ -> a) -> a = fun main ->
11571157
discontinue k ex
11581158
)
11591159
| Eio_unix.Private.Pipe sw -> Some (fun k ->
1160-
let r, w = Unix.pipe ~cloexec:true () in
1161-
let r = Luv_unix.Os_fd.Fd.from_unix r |> or_raise |> Luv.File.open_osfhandle |> or_raise in
1162-
let w = Luv_unix.Os_fd.Fd.from_unix w |> or_raise |> Luv.File.open_osfhandle |> or_raise in
1160+
let r, w = Luv.Pipe.pipe ~read_flags:[] ~write_flags:[] () |> or_raise in
11631161
let r = (flow (File.of_luv ~close_unix:true ~sw r) :> <Eio.Flow.source; Eio.Flow.close; Eio_unix.unix_fd>) in
11641162
let w = (flow (File.of_luv ~close_unix:true ~sw w) :> <Eio.Flow.sink; Eio.Flow.close; Eio_unix.unix_fd>) in
11651163
continue k (r, w)

0 commit comments

Comments
 (0)