Module Async_extended.Durable_subscription

module Update : sig ... end

val create : Async.Rpc.Connection.t Durable.t ‑> ('query, 'response, 'error) Async.Rpc.Pipe_rpc.t ‑> query:'query ‑> resubscribe_delay:Core.Time.Span.t ‑> ('response, 'error) Update.t Async.Pipe.Reader.t

val create_or_fail : Async.Rpc.Connection.t Durable.t ‑> ('query, 'response, 'error) Async.Rpc.Pipe_rpc.t ‑> query:'query ‑> resubscribe_delay:Core.Time.Span.t ‑> (('response, 'error) Update.t Async.Pipe.Reader.t, 'error) Core.Result.t Core.Or_error.t Async.Deferred.t