let timeout, send_timeout = E.create () in
    let timeout_task =
      lwt () = Lwt_unix.sleep timeout in
      send_timeout `timeout;
      return ()
    in
      E.select
        [
          data_event;
          timeout
        ]