package async_durable
-
async_durable
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
package async_durable
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Expert is only used to build Durable_pipe_rpc off the same implementation as Durable_state_rpc. If other similar Rpcs come into being, they can also take advantage.
val create :
?time_source:Async_kernel.Time_source.t ->
'connection Async_durable__.Durable.t ->
dispatch:
('connection ->
('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error)
Core.Result.t
Core.Or_error.t
Async_kernel.Deferred.t) ->
resubscribe_delay:Core.Time.Span.t ->
('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.tval create_or_fail :
?time_source:Async_kernel.Time_source.t ->
'connection Async_durable__.Durable.t ->
dispatch:
('connection ->
('state * 'update Async_kernel.Pipe.Reader.t * 'metadata, 'error)
Core.Result.t
Core.Or_error.t
Async_kernel.Deferred.t) ->
resubscribe_delay:Core.Time.Span.t ->
(('state, 'update, 'error, 'metadata) Update.t Async_kernel.Pipe.Reader.t,
'error)
Core.Result.t
Core.Or_error.t
Async_kernel.Deferred.t