package babel

You can search for identifiers within the package.

in-package search v0.2.0

babel
- CHANGES
- LICENSE
- README
- Library babel
  - Babel
    
    Callee
    
    Rpc
    
    Rpc'
    
    Pipe_rpc
    
    Pipe_rpc_direct
    
    Direct_stream_writer
    
    Expert
    
    Transformation_id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    For_testing
    
    Group
    
    For_testing
    
    State_rpc
    
    One_way
    
    Streamable_plain_rpc
    
    Streamable_pipe_rpc
    
    Streamable_state_rpc
    
    Caller
    
    Rpc
    
    Rpc_exn
    
    Rpc'
    
    Pipe_rpc
    
    Pipe_rpc_exn
    
    Pipe_rpc_iter
    
    Id
    
    State_rpc
    
    One_way
    
    One_way_exn
    
    One_way'
    
    Streamable_plain_rpc
    
    Streamable_pipe_rpc
    
    Streamable_state_rpc
    
    Expert
    
    Generic_rpc
    
    Shape
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
- Sources
  - babel
    
    babel.ml
    
    babel__.ml
    
    babel_fn.ml
    
    callee.ml
    
    caller.ml
    
    direct_stream_writer.ml
    
    generic_rpc.ml
    
    pipe_extended.ml
    
    shape.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Caller.Pipe_rpc_exn`Source

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

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

Source

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

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

Source

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

Create a new caller supporting a single rpc.

Source

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

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

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

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

Source

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

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

Sometimes, Caller.Pipe_rpc_exn.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.

Source

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

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

package babel

Module Caller.Pipe_rpc_exnSource

Module `Caller.Pipe_rpc_exn`Source