graph.ml

let beacon =
  new beacon ~zero:(fun() -> 0) ~next:(fun v -> v + 1)

let apply_fn (v0, v1) =
  Logs_lwt.info (fun m -> m "(%d, %d)" v0 v1)
  >>= fun () -> Lwt.return (v0, v1)

let () =
  Logs.set_reporter (Logs.format_reporter ());
  Logs.set_level (Some Logs.Info);
  (* Streams *)
  [%fstream
    (Vertex("B0", beacon) +> Vertex("B1", beacon))
    *>
    Vertex("M0", new merge)
    +>
    Vertex("M0", ())
    *>
    Vertex("A0", new apply ~fn:apply_fn)
    +>
    Vertex("A0", ())
    *>
    Vertex("S0", new sink)
  ]
  |> List.map(fun e -> e#process)
  |> Lwt.join
  |> Lwt_main.run