async_durable

Durable connections for use with async
IN THIS PACKAGE
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