package async_durable

  1. Overview
  2. Docs

Expert is only used to build Durable_pipe_rpc off the same implementation as Durable_state_rpc. If other similar Rpcs come into being, they can also take advantage.

val create : ?time_source:Async_kernel.Time_source.t -> 'connection Async_durable__.Durable.t -> dispatch: ('connection -> ('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error) Core.Result.t Core.Or_error.t Async_kernel.Deferred.t) -> resubscribe_delay:Core.Time.Span.t -> ('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.t
val create_or_fail : ?time_source:Async_kernel.Time_source.t -> 'connection Async_durable__.Durable.t -> dispatch: ('connection -> ('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error) Core.Result.t Core.Or_error.t Async_kernel.Deferred.t) -> resubscribe_delay:Core.Time.Span.t -> (('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.t, 'error) Core.Result.t Core.Or_error.t Async_kernel.Deferred.t
OCaml

Innovation. Community. Security.