Module Trading_engine.Scenario_stream

Bounded-memory reader for versioned JSON Lines replay scenarios.

val fold_channel : ?max_record_bytes:int -> Stdlib.in_channel -> init:(Scenario.stream_header -> ('state, Diagnostic.t) Stdlib.result) -> step:('state -> Scenario.stream_item -> ('state, Diagnostic.t) Stdlib.result) -> finish:('state -> slice_count:int64 -> ('result, Diagnostic.t) Stdlib.result) -> ('result, Diagnostic.t) Stdlib.result
val fold_file : ?max_record_bytes:int -> string -> init:(Scenario.stream_header -> ('state, Diagnostic.t) Stdlib.result) -> step:('state -> Scenario.stream_item -> ('state, Diagnostic.t) Stdlib.result) -> finish:('state -> slice_count:int64 -> ('result, Diagnostic.t) Stdlib.result) -> ('result, Diagnostic.t) Stdlib.result