async_durable

Durable connections for use with async
IN THIS PACKAGE
module Update : sig ... end
val create : ?time_source:Async_kernel.Time_source.t -> Async_rpc_kernel.Rpc.Connection.t Async_durable__Durable.t -> ( 'query, 'response, 'error ) Async_rpc_kernel.Rpc.Pipe_rpc.t -> query:'query -> resubscribe_delay:Core.Time.Span.t -> ( 'response, 'error ) Update.t Async_kernel.Pipe.Reader.t
val create_or_fail : ?time_source:Async_kernel.Time_source.t -> Async_rpc_kernel.Rpc.Connection.t Async_durable__Durable.t -> ( 'query, 'response, 'error ) Async_rpc_kernel.Rpc.Pipe_rpc.t -> query:'query -> resubscribe_delay:Core.Time.Span.t -> ( ( 'response, 'error ) Update.t Async_kernel.Pipe.Reader.t, 'error ) Core.Result.t Core.Or_error.t Async_kernel.Deferred.t