Module `Durable_state_rpc.Expert`

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 : 'connection Async_durable__.Durable.t -> dispatch:('connection -> ('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t) -> resubscribe_delay:Core_kernel.Time.Span.t -> ('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.t
val create_or_fail : 'connection Async_durable__.Durable.t -> dispatch:('connection -> ('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t) -> resubscribe_delay:Core_kernel.Time.Span.t -> (('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.t, 'error) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t