obus 1.1.8 · OCaml Package

type t

val compare : t -> t -> int

val of_addresses : 
  ?switch:Lwt_switch.t ->
  ?shared:bool ->
  OBus_address.t list ->
  t Lwt.t

val loopback : unit -> t

val close : t -> unit Lwt.t

val active : t -> bool React.signal

exception Connection_closed

exception Connection_lost

exception Transport_error of exn

val name : t -> OBus_name.bus

val set_name : t -> OBus_name.bus -> unit

val transport : t -> OBus_transport.t

val can_send_basic_type : t -> OBus_value.T.basic -> bool

val can_send_single_type : t -> OBus_value.T.single -> bool

val can_send_sequence_type : t -> OBus_value.T.sequence -> bool

val send_message : t -> OBus_message.t -> unit Lwt.t

val send_message_with_reply : t -> OBus_message.t -> OBus_message.t Lwt.t

val send_message_keep_serial : t -> OBus_message.t -> unit Lwt.t

val send_message_keep_serial_with_reply : 
  t ->
  OBus_message.t ->
  OBus_message.t Lwt.t

val method_call : 
  connection:t ->
  ?destination:OBus_name.bus ->
  path:OBus_path.t ->
  ?interface:OBus_name.interface ->
  member:OBus_name.member ->
  i_args:'a OBus_value.C.sequence ->
  o_args:'b OBus_value.C.sequence ->
  'a ->
  'b Lwt.t

val method_call_with_message : 
  connection:t ->
  ?destination:OBus_name.bus ->
  path:OBus_path.t ->
  ?interface:OBus_name.interface ->
  member:OBus_name.member ->
  i_args:'a OBus_value.C.sequence ->
  o_args:'b OBus_value.C.sequence ->
  'a ->
  (OBus_message.t * 'b) Lwt.t

val method_call_no_reply : 
  connection:t ->
  ?destination:OBus_name.bus ->
  path:OBus_path.t ->
  ?interface:OBus_name.interface ->
  member:OBus_name.member ->
  i_args:'a OBus_value.C.sequence ->
  'a ->
  unit Lwt.t

type filter = OBus_message.t -> OBus_message.t option

val incoming_filters : t -> filter Lwt_sequence.t

val outgoing_filters : t -> filter Lwt_sequence.t

type 'a key

val new_key : unit -> 'a key

val get : t -> 'a key -> 'a option

val set : t -> 'a key -> 'a option -> unit

val set_on_disconnect : t -> (exn -> unit Lwt.t) -> unit

val of_transport : 
  ?switch:Lwt_switch.t ->
  ?guid:OBus_address.guid ->
  ?up:bool ->
  OBus_transport.t ->
  t

val state : t -> [ `Up | `Down ] React.signal

val set_up : t -> unit

val set_down : t -> unit

package obus