A simple TCP broadcaster

broadcaster.ml

open Lwt

let establish saddr caddr =
  let open Lwt_io in
  let str,push = Lwt_stream.create () in
  let client (g,p) =
    let rec loop () = write_chars p str >> loop () in
    ignore_result (loop ()) in
  let hsrv = establish_server saddr client in
  lwt g,p  = open_connection caddr in
  let rec server_loop () = try_lwt
      lwt ch = read_char g in
      push (Some ch);
      server_loop () with
    End_of_file -> return (push None) in
  server_loop () >> return (shutdown_server hsrv)