sig
  type ('query, 'response) t
  val create :
    send_header:Send_tag.t Ib.Header.t ->
    recv_header:Recv_tag.t Ib.Header.t ->
    tws_query:'query Tws_prot.Pickler.t ->
    tws_response:'response Tws_prot.Unpickler.t ->
    ('query, 'response) Ib.Request.t
  val dispatch :
    ('query, 'response) Ib.Request.t ->
    Ib.Connection.t ->
    'query -> 'response Core.Std.Or_error.t Async.Std.Deferred.t
end