Module Async_durable__.Durable_subscription
module Update : sig ... endval create : 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_kernel.Time.Span.t -> ('response, 'error) Update.t Async_kernel.Pipe.Reader.tval create_or_fail : 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_kernel.Time.Span.t -> (('response, 'error) Update.t Async_kernel.Pipe.Reader.t, 'error) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t