package streamable

You can search for identifiers within the package.

in-package search v0.2.0

On This Page

Parameters
Signature

package streamable

streamable
- LICENSE
- Library ppx_streamable
  - Ppx_streamable
    
    For_testing
    
    Nested_variant
    
    For_testing
    
    Path
    
    Nested_tuple
    
    For_testing
- Library streamable
  - Streamable
    
    S
    
    Intermediate
    
    Part
    
    S_rpc
    
    Intermediate
    
    Part
    
    S_rpc_with_sexp_of_part
    
    Intermediate
    
    Part
    
    Of_atomic
    
    Intermediate
    
    Part
    
    Of_atomic_rpc
    
    Intermediate
    
    Part
    
    Of_map
    
    Intermediate
    
    Part
    
    Of_map_rpc
    
    Intermediate
    
    Part
    
    Of_total_map
    
    Intermediate
    
    Part
    
    Of_total_map_rpc
    
    Intermediate
    
    Part
    
    Of_hashtbl
    
    Intermediate
    
    Part
    
    Of_hashtbl_rpc
    
    Intermediate
    
    Part
    
    Of_set
    
    Intermediate
    
    Part
    
    Of_set_rpc
    
    Intermediate
    
    Part
    
    Of_tuple2
    
    Intermediate
    
    Part
    
    Of_tuple2_rpc
    
    Intermediate
    
    Part
    
    Of_tuple3
    
    Intermediate
    
    Part
    
    Of_tuple3_rpc
    
    Intermediate
    
    Part
    
    Of_tuple4
    
    Intermediate
    
    Part
    
    Of_tuple4_rpc
    
    Intermediate
    
    Part
    
    Of_tuple5
    
    Intermediate
    
    Part
    
    Of_tuple5_rpc
    
    Intermediate
    
    Part
    
    Of_tuple6
    
    Intermediate
    
    Part
    
    Of_tuple6_rpc
    
    Intermediate
    
    Part
    
    Of_variant2
    
    Intermediate
    
    Part
    
    Of_variant2_rpc
    
    Intermediate
    
    Part
    
    Of_variant3
    
    Intermediate
    
    Part
    
    Of_variant3_rpc
    
    Intermediate
    
    Part
    
    Of_variant4
    
    Intermediate
    
    Part
    
    Of_variant4_rpc
    
    Intermediate
    
    Part
    
    Of_list
    
    Intermediate
    
    Part
    
    Of_list_rpc
    
    Intermediate
    
    Part
    
    Of_nonempty_list
    
    Intermediate
    
    Part
    
    Of_nonempty_list_rpc
    
    Intermediate
    
    Part
    
    Of_option
    
    Intermediate
    
    Part
    
    Of_option_rpc
    
    Intermediate
    
    Part
    
    Of_result
    
    Intermediate
    
    Part
    
    Of_result_rpc
    
    Intermediate
    
    Part
    
    Of_fqueue
    
    Intermediate
    
    Part
    
    Of_fqueue_rpc
    
    Intermediate
    
    Part
    
    Of_sequence
    
    Intermediate
    
    Part
    
    Of_sequence_rpc
    
    Intermediate
    
    Part
    
    Of_streamable
    
    Intermediate
    
    Part
    
    Of_streamable_rpc
    
    Intermediate
    
    Part
    
    Fixpoint
    
    Intermediate
    
    Part
    
    Fixpoint_rpc
    
    Intermediate
    
    Part
    
    Checked
    
    Intermediate
    
    Part
    
    Packed
    
    Intermediate
    
    Part
    
    Packed_rpc
    
    Intermediate
    
    Part
    
    Of_atomic
    
    Intermediate
    
    Part
    
    Of_atomic_rpc
    
    Intermediate
    
    Part
    
    Of_map
    
    Intermediate
    
    Part
    
    Of_map_rpc
    
    Intermediate
    
    Part
    
    Of_total_map
    
    Intermediate
    
    Part
    
    Of_total_map_rpc
    
    Intermediate
    
    Part
    
    Of_hashtbl
    
    Intermediate
    
    Part
    
    Of_hashtbl_rpc
    
    Intermediate
    
    Part
    
    Of_set
    
    Intermediate
    
    Part
    
    Of_set_rpc
    
    Intermediate
    
    Part
    
    Of_tuple2
    
    Intermediate
    
    Part
    
    Of_tuple2_rpc
    
    Intermediate
    
    Part
    
    Of_tuple3
    
    Intermediate
    
    Part
    
    Of_tuple3_rpc
    
    Intermediate
    
    Part
    
    Of_tuple4
    
    Intermediate
    
    Part
    
    Of_tuple4_rpc
    
    Intermediate
    
    Part
    
    Of_tuple5
    
    Intermediate
    
    Part
    
    Of_tuple5_rpc
    
    Intermediate
    
    Part
    
    Of_tuple6
    
    Intermediate
    
    Part
    
    Of_tuple6_rpc
    
    Intermediate
    
    Part
    
    Of_tuple7
    
    Intermediate
    
    Part
    
    Of_tuple7_rpc
    
    Intermediate
    
    Part
    
    Of_tuple8
    
    Intermediate
    
    Part
    
    Of_tuple8_rpc
    
    Intermediate
    
    Part
    
    Of_tuple9
    
    Intermediate
    
    Part
    
    Of_tuple9_rpc
    
    Intermediate
    
    Part
    
    Of_variant2
    
    Intermediate
    
    Part
    
    Of_variant2_rpc
    
    Intermediate
    
    Part
    
    Of_variant3
    
    Intermediate
    
    Part
    
    Of_variant3_rpc
    
    Intermediate
    
    Part
    
    Of_variant4
    
    Intermediate
    
    Part
    
    Of_variant4_rpc
    
    Intermediate
    
    Part
    
    Of_list
    
    Intermediate
    
    Part
    
    Of_list_rpc
    
    Intermediate
    
    Part
    
    Of_nonempty_list
    
    Intermediate
    
    Part
    
    Of_nonempty_list_rpc
    
    Intermediate
    
    Part
    
    Of_option
    
    Intermediate
    
    Part
    
    Of_option_rpc
    
    Intermediate
    
    Part
    
    Of_result
    
    Intermediate
    
    Part
    
    Of_result_rpc
    
    Intermediate
    
    Part
    
    Of_fqueue
    
    Intermediate
    
    Part
    
    Of_fqueue_rpc
    
    Intermediate
    
    Part
    
    Of_sequence
    
    Intermediate
    
    Part
    
    Of_sequence_rpc
    
    Intermediate
    
    Part
    
    Of_streamable
    
    Intermediate
    
    Part
    
    Of_streamable_rpc
    
    Intermediate
    
    Part
    
    Of_sexpable
    
    Intermediate
    
    Part
    
    Fixpoint
    
    Intermediate
    
    Part
    
    Fixpoint_rpc
    
    Intermediate
    
    Part
    
    Checked
    
    Intermediate
    
    Part
    
    Packed
    
    Intermediate
    
    Part
    
    Packed_rpc
    
    Intermediate
    
    Part
    
    Remove_t_rpc
    
    Remove_t
    
    Stable
    
    S
    
    Intermediate
    
    Part
    
    S_rpc
    
    Intermediate
    
    Part
    
    S_rpc_with_sexp_of_part
    
    Intermediate
    
    Part
    
    Remove_t
    
    Remove_t_rpc
    
    Checked
    
    Intermediate
    
    Part
    
    Packed
    
    V1
    
    Intermediate
    
    Part
    
    Packed_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Fixpoint
    
    V1
    
    Intermediate
    
    Part
    
    Fixpoint_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_atomic
    
    V1
    
    Intermediate
    
    Part
    
    Of_atomic_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_fqueue
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_fqueue_rpc
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_hashtbl
    
    V1
    
    Intermediate
    
    Part
    
    Of_hashtbl_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_list
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_list_rpc
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_nonempty_list
    
    V1
    
    Intermediate
    
    Part
    
    Of_nonempty_list_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_map
    
    V1
    
    Intermediate
    
    Part
    
    V2
    
    Intermediate
    
    Part
    
    Of_map_rpc
    
    V1
    
    Intermediate
    
    Part
    
    V2
    
    Intermediate
    
    Part
    
    Of_total_map
    
    V1
    
    Intermediate
    
    Part
    
    Of_total_map_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_option
    
    V1
    
    Intermediate
    
    Part
    
    V2
    
    Intermediate
    
    Part
    
    Of_option_rpc
    
    V1
    
    Intermediate
    
    Part
    
    V2
    
    Intermediate
    
    Part
    
    Of_result
    
    V1
    
    Intermediate
    
    Part
    
    Of_result_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_set
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_set_rpc
    
    V2
    
    Intermediate
    
    Part
    
    V3
    
    Intermediate
    
    Part
    
    Of_sequence
    
    V1
    
    Intermediate
    
    Part
    
    Of_sequence_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_streamable
    
    V1
    
    Intermediate
    
    Part
    
    Of_streamable_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple2
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple2_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple3
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple3_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple4
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple4_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple5
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple5_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple6
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple6_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple7
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple7_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple8
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple8_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple9
    
    V1
    
    Intermediate
    
    Part
    
    Of_tuple9_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant2
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant2_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant3
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant3_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant4
    
    V1
    
    Intermediate
    
    Part
    
    Of_variant4_rpc
    
    V1
    
    Intermediate
    
    Part
    
    Of_sexpable
    
    V1
    
    Intermediate
    
    Part
    
    V1
    
    Fixpoint
    
    Fixpoint_rpc
    
    Of_atomic
    
    Of_atomic_rpc
    
    Of_fqueue
    
    Of_fqueue_rpc
    
    Of_hashtbl
    
    Of_hashtbl_rpc
    
    Of_list
    
    Of_list_rpc
    
    Of_map
    
    Of_map_rpc
    
    Of_nonempty_list
    
    Of_nonempty_list_rpc
    
    Of_option
    
    Of_option_rpc
    
    Of_result
    
    Of_result_rpc
    
    Of_sequence
    
    Of_sequence_rpc
    
    Of_set
    
    Of_set_rpc
    
    Of_sexpable
    
    Of_streamable
    
    Of_streamable_rpc
    
    Of_total_map
    
    Of_total_map_rpc
    
    Of_tuple2
    
    Of_tuple2_rpc
    
    Of_tuple3
    
    Of_tuple3_rpc
    
    Of_tuple4
    
    Of_tuple4_rpc
    
    Of_tuple5
    
    Of_tuple5_rpc
    
    Of_tuple6
    
    Of_tuple6_rpc
    
    Of_tuple7
    
    Of_tuple7_rpc
    
    Of_tuple8
    
    Of_tuple8_rpc
    
    Of_tuple9
    
    Of_tuple9_rpc
    
    Of_variant2
    
    Of_variant2_rpc
    
    Of_variant3
    
    Of_variant3_rpc
    
    Of_variant4
    
    Of_variant4_rpc
    
    Remove_t
    
    Remove_t_rpc
    
    Plain_rpc
    
    S
    
    Response
    
    Intermediate
    
    Part
    
    Make
    
    Pipe_rpc
    
    S
    
    Response
    
    Intermediate
    
    Part
    
    Make
    
    State_rpc
    
    S
    
    State
    
    Intermediate
    
    Part
    
    Update
    
    Intermediate
    
    Part
    
    Direct_writer
    
    Group
    
    Make
    
    Versioned_plain_rpc
    
    Caller_converts
    
    Callee_converts
    
    Both_convert
    
    Caller_converts
    
    S
    
    Make
    
    Register
    
    Callee_converts
    
    S
    
    Make
    
    Register
    
    Both_convert
    
    S
    
    Make
    
    Register
    
    Versioned_pipe_rpc
    
    Caller_converts
    
    Callee_converts
    
    Both_convert
    
    Caller_converts
    
    S
    
    Make
    
    Register
    
    Callee_converts
    
    S
    
    Make
    
    Register
    
    Both_convert
    
    S
    
    Make
    
    Register
    
    Versioned_state_rpc
    
    Caller_converts
    
    Callee_converts
    
    Both_convert
    
    Caller_converts
    
    S
    
    Make
    
    Register
    
    Callee_converts
    
    S
    
    Make
    
    Register
    
    Both_convert
    
    S
    
    Make
    
    Register
- Sources
  - ppx_streamable
    
    atomic_clause.ml
    
    attributes.ml
    
    clause.ml
    
    core_primitive_clause.ml
    
    ctx.ml
    
    fqueue_clause.ml
    
    hashtbl_clause.ml
    
    helpers.ml
    
    import.ml
    
    keyed_container_clause.ml
    
    keyed_container_clause_intf.ml
    
    list_clause.ml
    
    map_clause.ml
    
    module_dot_t_clause.ml
    
    nested_tuple.ml
    
    nested_variant.ml
    
    nonempty_list_clause.ml
    
    option_clause.ml
    
    or_error_clause.ml
    
    parameterized_type_clause.ml
    
    ppx_streamable.ml
    
    ppx_streamable__.ml
    
    record_clause.ml
    
    result_clause.ml
    
    sequence_clause.ml
    
    set_clause.ml
    
    sexp_clause.ml
    
    total_map_clause.ml
    
    tuple_clause.ml
    
    type.ml
    
    type_parameter_clause.ml
    
    variant_clause.ml
    
    version.ml
  - streamable
    
    callers_rpc_version_table.ml
    
    import.ml
    
    main.ml
    
    main_intf.ml
    
    module_type.ml
    
    pipe_rpc.ml
    
    pipe_rpc_intf.ml
    
    plain_rpc.ml
    
    plain_rpc_intf.ml
    
    remove_t.ml
    
    state_rpc.ml
    
    state_rpc_intf.ml
    
    streamable.ml
    
    streamable__.ml
    
    versioned_pipe_rpc.ml
    
    versioned_pipe_rpc_intf.ml
    
    versioned_plain_rpc.ml
    
    versioned_plain_rpc_intf.ml
    
    versioned_state_rpc.ml
    
    versioned_state_rpc_intf.ml

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

Module `Pipe_rpc.Make`Source

Parameters

module X : S

Signature

Sourceval rpc : (X.query, X.response) t

Source

val implement' : 
  ?on_exception:Async_rpc_kernel.Rpc.On_exception.t ->
  ('conn_state ->
    X.query ->
    X.Response.Intermediate.Part.t Async_kernel.Pipe.Reader.t
      Async_kernel.Pipe.Reader.t
      Async_kernel.Deferred.Or_error.t) ->
  'conn_state Async_rpc_kernel.Rpc.Implementation.t

implement' is like implement rpc except that it allows the server to control the conversion from responses to parts.

package streamable

Module Pipe_rpc.MakeSource

Parameters

Signature

Module `Pipe_rpc.Make`Source