diff options
Diffstat (limited to 'prl_api')
| -rw-r--r-- | prl_api/sakura_prl_api.ml | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/prl_api/sakura_prl_api.ml b/prl_api/sakura_prl_api.ml index 92fd658..84337fb 100644 --- a/prl_api/sakura_prl_api.ml +++ b/prl_api/sakura_prl_api.ml @@ -15,12 +15,14 @@ let mutex = Mutex.create () let register symbol impl = Mutex.protect mutex (fun () -> Hashtbl.replace registry symbol impl) -let find symbol = Mutex.protect mutex (fun () -> Hashtbl.find_opt registry symbol) +let find symbol = + Mutex.protect mutex (fun () -> Hashtbl.find_opt registry symbol) let symbols () = Mutex.protect mutex (fun () -> Hashtbl.to_seq_keys registry |> List.of_seq) -let implementation_of_rows ?membership_criteria (rows : tuple list) : implementation = +let implementation_of_rows ?membership_criteria (rows : tuple list) : + implementation = { membership_criteria; produce = Some (fun _bindings -> Ok rows) } let implementation_of_producer ?membership_criteria |