Up

Module Expert

Signature

module Responder : sig .. end
val schedule_dispatch : Connection.t -> rpc_tag:string -> version:int -> Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> handle_response:(Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> unit Async_kernel.Std.Deferred.t) -> handle_error:(Core_kernel.Std.Error.t -> unit) -> [
| `Flushed of unit Async_kernel.Std.Deferred.t
| `Connection_closed
]

This just schedules a write, so the Bigstring.t should not be overwritten until the flushed Deferred.t is determined.

The return value of handle_response has the same meaning as in the function argument of Implementations.Expert.create.

val dispatch : Connection.t -> rpc_tag:string -> version:int -> Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> handle_response:(Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> unit Async_kernel.Std.Deferred.t) -> handle_error:(Core_kernel.Std.Error.t -> unit) -> [
| `Ok
| `Connection_closed
]
type implementation_result =
| Replied
| Delayed_response of unit Async_kernel.Std.Deferred.t

Result of callbacks passed to implement and implement':

  • Replied means that the response has already been sent using one of the functions of Responder
  • Delayed_response d means that the implementation is done using the input bigstring, but hasn't send the response yet. When d becomes determined it is expected that the response has been sent.

Note: it is not OK for an implementation to return:


          Delayed_response (Responder.schedule responder buf ~pos:... ~len:...)

where buf is the same bigstring as the one containing the query. This is because it would indicate that buf can be overwritten even though it is still being used by Responder.schedule.

val implement : (_, _) t -> ('connection_state -> Responder.t -> Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> implementation_result Async_kernel.Std.Deferred.t) -> 'connection_state Implementation.t
val implement' : (_, _) t -> ('connection_state -> Responder.t -> Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> implementation_result) -> 'connection_state Implementation.t