open Markup

type t = (signal, async) stream * ((signal, sync) stream option -> unit)

val stanza_open : ?from:string -> string -> (signal, sync) stream

val stanza_close : (signal, sync) stream

val connect : string -> t Lwt.t