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