package babel

You can search for identifiers within the package.

in-package search v0.2.0

babel
- Babel
  - Callee
    
    One_way
    
    Pipe_rpc
    
    Pipe_rpc_direct
    
    Direct_stream_writer
    
    Expert
    
    Transformation_id
    
    For_testing
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Group
    
    For_testing
    
    Rpc
    
    Rpc'
    
    State_rpc
    
    Streamable_pipe_rpc
    
    Streamable_plain_rpc
    
    Streamable_state_rpc
  - Caller
    
    Expert
    
    One_way
    
    One_way'
    
    One_way_exn
    
    Pipe_rpc
    
    Pipe_rpc_exn
    
    Pipe_rpc_iter
    
    Rpc
    
    Rpc'
    
    Rpc_exn
    
    State_rpc
    
    Streamable_pipe_rpc
    
    Streamable_plain_rpc
    
    Streamable_state_rpc
  - Generic_rpc
  - Shape
    
    Map
    
    Diff
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt

Legend:
Library
Module
Module type
Parameter
Class
Class type

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

module Id : Core.T

type ('q, 'r, 'e) dispatch :=
  'q ->
  f:
    ('r Async_rpc_kernel.Rpc.Pipe_rpc.Pipe_message.t ->
      Async_rpc_kernel.Rpc.Pipe_rpc.Pipe_response.t) ->
  (Id.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 use abort.

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.

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.

val abort : Id.t -> unit

Given the Id.t returned from dispatch_multi, cancel the subscription.