package links

  1. Overview
  2. Docs
type chan = Value.chan
val receive_port : chan -> ProcessTypes.channel_id
val send_port : chan -> ProcessTypes.channel_id
val cancel : chan -> unit Lwt.t
val is_endpoint_cancelled : ProcessTypes.channel_id -> bool
type send_result =
  1. | SendOK
  2. | SendPartnerCancelled
type receive_result =
  1. | ReceiveOK of Value.t
  2. | ReceiveBlocked
  3. | ReceivePartnerCancelled
val new_server_access_point : unit -> ProcessTypes.apid
val new_client_access_point : ProcessTypes.client_id -> ProcessTypes.apid
val get_and_mark_pending_aps : ProcessTypes.client_id -> ProcessTypes.apid list
val accept : ProcessTypes.apid -> (chan * bool) Lwt.t
val request : ProcessTypes.apid -> (chan * bool) Lwt.t
val ap_request_from_client : ProcessTypes.client_id -> ProcessTypes.process_id -> ProcessTypes.apid -> unit Lwt.t
val ap_accept_from_client : ProcessTypes.client_id -> ProcessTypes.process_id -> ProcessTypes.apid -> unit Lwt.t
val send_from_local : Value.t -> ProcessTypes.channel_id -> send_result Lwt.t
val receive : chan -> receive_result
val handle_lost_message_response : ProcessTypes.channel_id -> (ProcessTypes.channel_id * Value.t list) list -> unit Lwt.t
val handle_remote_cancel : notify_ep:ProcessTypes.channel_id -> cancelled_ep:ProcessTypes.channel_id -> unit Lwt.t
val cancel_client_channels : ProcessTypes.client_id -> unit Lwt.t
val register_client_channel : ProcessTypes.client_id -> chan -> unit
val register_server_channel : chan -> unit
val get_buffer : ProcessTypes.channel_id -> Value.t list option
val close : chan -> unit
OCaml

Innovation. Community. Security.