List.iter_ep
      (fun conn ->
        trace Read @@ P2p_conn.read conn
        >>=? Node.(
               function
               | Ping -> Event.(emit received_ping) () >>= fun () -> return_unit
               | Whois -> return_unit))