package async_durable

  1. Overview
  2. Docs
module Update : sig ... end
val create : ?time_source:Async_kernel.Time_source.t -> Async_rpc_kernel.Rpc.Connection.t Async_durable__.Durable.t -> ('query, 'response, 'error) Async_rpc_kernel.Rpc.Pipe_rpc.t -> query:'query -> resubscribe_delay:Core.Time.Span.t -> ('response, 'error) Update.t Async_kernel.Pipe.Reader.t
  • deprecated [since 2018-04] use Durable_pipe_rpc instead
val create_or_fail : ?time_source:Async_kernel.Time_source.t -> Async_rpc_kernel.Rpc.Connection.t Async_durable__.Durable.t -> ('query, 'response, 'error) Async_rpc_kernel.Rpc.Pipe_rpc.t -> query:'query -> resubscribe_delay:Core.Time.Span.t -> (('response, 'error) Update.t Async_kernel.Pipe.Reader.t, 'error) Core.Result.t Core.Or_error.t Async_kernel.Deferred.t
  • deprecated [since 2018-04] use Durable_pipe_rpc instead