Module Ib.Streaming_request_without_id

module Streaming_request_without_id: sig .. end

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) t

val dispatch : ('query, 'response) t ->
       Ib.Connection.t ->
       'query ->
       'response Async.Std.Pipe.Reader.t Core.Std.Or_error.t Async.Std.Deferred.t

val cancel : ('a, 'b) t -> Ib.Connection.t -> unit