babel v0.17.0 · OCaml Package

High level functions for working with callers in the style of Async.Rpc.Pipe_rpc.dispatch.

type ('q, 'r, 'e) dispatch :=
  'q ->
  ('r Async_kernel.Pipe.Reader.t * Async_rpc_kernel.Rpc.Pipe_rpc.Metadata.t,
    'e)
    Core.Result.t
    Core.Or_error.t
    Async_kernel.Deferred.t

val dispatch_multi : 
  ('q, 'r, 'e) dispatch t ->
  Async_rpc_kernel.Versioned_rpc.Connection_with_menu.t ->
  ('q, 'r, 'e) dispatch

Determine which supported dispatch strategy to use and invoke the chosen rpcs. To unsubscribe, you can close the pipe.

val singleton : 
  ('q, 'r, 'e) Async_rpc_kernel.Rpc.Pipe_rpc.t ->
  ('q, 'r, 'e) dispatch t

Create a new caller supporting a single rpc.

val add : 
  ('q, 'r, 'e) dispatch t ->
  rpc:('q, 'r, 'e) Async_rpc_kernel.Rpc.Pipe_rpc.t ->
  ('q, 'r, 'e) dispatch t

Add support for dispatching another rpc. dispatch_multi will prefer this rpc over the ones the caller already supports.

val map_query : 
  ('q1, 'r, 'e) dispatch t ->
  f:('q2 -> 'q1) ->
  ('q2, 'r, 'e) dispatch t

A specialization of map for the query type of a protocol.

val map_response : 
  ('q, 'r1, 'e) dispatch t ->
  f:('r1 -> 'r2) ->
  ('q, 'r2, 'e) dispatch t

A specialization of map for the response type of a protocol.

Sometimes, Caller.Pipe_rpc.map_response is not sufficient. For example, sometimes it might not be possible to convert the response to the desired type, in which case it may be appropriate to drop the value from the pipe entirely. For such cases, use Caller.map_response instead. It gives you access to the pipe itself, not just the values inside it, allowing you to use something like Pipe.filter_map.

val filter_map_response : 
  ('q, 'r1, 'e) dispatch t ->
  f:('r1 -> 'r2 option) ->
  ('q, 'r2, 'e) dispatch t

Same as map_response but filters out some responses from the response pipe

val map_error : 
  ('q, 'r, 'e1) dispatch t ->
  f:('e1 -> 'e2) ->
  ('q, 'r, 'e2) dispatch t

A specialization of map for the error type of a protocol.

package babel