Module Durable_subscription

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

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