Dsl (integration_test_lib.Integration_test

module Timeout = Timeout_lib.Core_time

val broadcast_pipe_fold_until_with_timeout : 
  'a Pipe_lib.Broadcast_pipe.Reader.t ->
  timeout_duration:Core_kernel__.Time_float0.Span.t ->
  timeout_result:'b ->
  init:'c ->
  f:( 'd -> 'e -> [< `Continue of 'f | `Stop of 'g ] ) ->
  'h Async_kernel__Deferred.t

module Make
  (Engine : Intf.Engine.S)
  () : 
  Intf.Dsl.S with module Engine := Engine