Repodb.Stream.Make

repodb · API reference

Parameters

module D : Driver.S

Signature

type connection = D.connection

type error = D.error

val fold : 
  connection ->
  string ->
  params:Driver.Value.t array ->
  init:'acc ->
  f:('acc -> Driver.row -> 'acc) ->
  ('acc, error) result

val iter : 
  connection ->
  string ->
  params:Driver.Value.t array ->
  f:(Driver.row -> unit) ->
  (unit, error) result

val fold_map : 
  connection ->
  string ->
  params:Driver.Value.t array ->
  f:(Driver.row -> 'a) ->
  ('a list, error) result

val cursor_fold : 
  connection ->
  config:config ->
  string ->
  params:Driver.Value.t array ->
  init:'acc ->
  f:('acc -> Driver.row -> 'acc) ->
  ('acc, error) result

val cursor_iter : 
  connection ->
  config:config ->
  string ->
  params:Driver.Value.t array ->
  f:(Driver.row -> unit) ->
  (unit, error) result