let write_and_read () : unit Deferred.t = let (r, w) = Pipe.create () in don't_wait_for (Pipe.write w 42); Pipe.read r >>| function | `Eof -> failwith "impossible" | `Ok y -> printf "y = %d\n" y