Up

module Durable_subscription

: sig
#
module Update : sig
#
type ('response, 'error) t =
# | Attempting_new_connection
# | Connection_success of Async.Std.Rpc.Pipe_rpc.Id.t
# | Lost_connection
# | Failed_to_connect of Core.Std.Error.t
# | Rpc_error of 'error
# | Update of 'response
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
end