diff --git a/relay.ml b/relay.ml index 339d82e..204052d 100644 --- a/relay.ml +++ b/relay.ml @@ -61,7 +61,7 @@ let issue_banner cin cout = let relay_boot (peername, cin, cout) = return (peername, Lwt_mutex.create (), cin, cout) let relay_handler (_, mtx, _, cout) _ m = - Lwt_mutex.with_lock mtx (fun () -> output_sexp_and_flush cout m) + Lwt_mutex.with_lock mtx (fun () -> output_sexp cout m) let relay_mainloop (peername, mtx, cin, cout) n = let write_sexp sexp = Lwt_mutex.with_lock mtx (fun () -> output_sexp cout sexp) in