Source file expert1.ml

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
34
35
open! Core
open! Import

module Dependency = struct
  type 'a t = 'a Expert.edge [@@deriving sexp_of]

  let create ?(on_change = ignore) child : _ t = { child; on_change; index = Uopt.none }

  let value (t : _ t) =
    let state = t.child.state in
    if debug
    then
      State.Expert.assert_currently_running_node_is_parent
        state
        t.child
        "Dependency.value";
    (* Not exposing the _exn, because this function is advertised as being usable only
       inside the callbacks of parents, where it will not raise. *)
    Node.value_exn t.child
  ;;
end

module Node = struct
  type nonrec 'a t = 'a Node.t [@@deriving sexp_of]

  let create state ?(on_observability_change = fun ~is_now_observable:_ -> ()) f =
    State.Expert.create state ~on_observability_change f
  ;;

  let make_stale = State.Expert.make_stale
  let watch = Fn.id
  let invalidate = State.Expert.invalidate
  let add_dependency = State.Expert.add_dependency
  let remove_dependency = State.Expert.remove_dependency
end