async_durable
Durable connections for use with async
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Library async_durable
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