1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
(*
* nm_monitor.ml
* -------------
* Copyright : (c) 2011, Jeremie Dimino <jeremie@dimino.org>
* Licence : BSD3
*
* This file is a part of obus, an ocaml implementation of D-Bus.
*)
open Lwt_react
open Lwt
open OBus_value
module String_map = Map.Make(String)
let properties_changed interface =
OBus_member.Signal.make
~interface
~member:"PropertiesChanged"
~args:(arg1 (Some "properties", C.dict C.string C.variant))
~annotations:[]
let monitor proxy interface switch =
let%lwt event =
OBus_signal.connect ~switch
(OBus_signal.with_context
(OBus_signal.make (properties_changed interface) proxy))
and context, dict = OBus_property.get_all_no_cache proxy interface in
return (S.fold_s ~eq:(String_map.equal (=))
(fun map (context, updates) ->
return (OBus_property.update_map context updates map))
(OBus_property.map_of_list context dict)
event)
|
