sig
  type ('query, 'response) t
  val create :
    ?skip_header:Recv_tag.t Ib.Header.t list ->
    send_header:Send_tag.t Ib.Header.t ->
    recv_header:Recv_tag.t Ib.Header.t list ->
    tws_query:'query Tws_prot.Pickler.t ->
    tws_response:'response Tws_prot.Unpickler.t list ->
    unit -> ('query, 'response) Ib.Streaming_request_without_id.t
  val dispatch :
    ('query, 'response) Ib.Streaming_request_without_id.t ->
    Ib.Connection.t ->
    'query ->
    'response Async.Std.Pipe.Reader.t Core.Std.Or_error.t
    Async.Std.Deferred.t
  val cancel :
    ('a, 'b) Ib.Streaming_request_without_id.t -> Ib.Connection.t -> unit
end