Up

Module Durable_subscription = Durable_subscription

Signature

module Update : sig .. end
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