package babel

You can search for identifiers within the package.

in-package search v0.2.0

package babel

babel
- Babel
  - Callee
    
    One_way
    
    Pipe_rpc
    
    Pipe_rpc_direct
    
    Direct_stream_writer
    
    Expert
    
    Transformation_id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    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
    
    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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt

Legend:
Library
Module
Module type
Parameter
Class
Class type

type -'a t

Like Rpc.Pipe_rpc.Direct_stream_writer, but with the additional ability to map functions over its inputs.

val create : 'a Async_rpc_kernel.Rpc.Pipe_rpc.Direct_stream_writer.t -> 'a t

Create a Babel-friendly direct stream writer from a raw Async_rpc one.

The result of map_input and filter_map_input writes to the same underlying Rpc.Pipe_rpc.Direct_stream_writer.t that the original t does.

val map_input : 'a t -> f:('b -> 'a) -> 'b t

val filter_map_input : 'a t -> f:('b -> 'a option) -> 'b t

These functions work the same way as the ones in Rpc.Pipe_rpc.Direct_stream_writer.

val write : 
  'a t ->
  'a ->
  [ `Flushed of unit Async_kernel.Deferred.t | `Closed ]

val write_without_pushback : 'a t -> 'a -> [ `Ok | `Closed ]

val close : _ t -> unit

val closed : _ t -> unit Async_kernel.Deferred.t

val flushed : _ t -> unit Async_kernel.Deferred.t

val is_closed : _ t -> bool

module Expert : sig ... end

module Group : sig ... end

Like Rpc.Pipe_rpc.Direct_stream_writer.Group, but with the ability to maintain multiple subgroups. One Rpc.Pipe_rpc.Direct_stream_writer.Group is maintained per implemented RPC, so values are only converted and serialized once per RPC.