Commits

Oliver Gu committed ad8da6c

Removed dispatch_exn in requests and streaming requests

Comments (0)

Files changed (2)

       | Error `Closed -> Ivar.fill ivar (Error Ibx_error.Connection_closed)
     end;
     Ivar.read ivar >>| Ibx_result.or_error
-
-  let dispatch_exn t con query = dispatch t con query >>| Or_error.ok_exn
 end
 
 module Streaming_request = struct
     end;
     Ivar.read ivar >>| Ibx_result.or_error
 
-  let dispatch_exn t con query = dispatch t con query >>| Or_error.ok_exn
-
   let cancel t con query_id =
     let recv_header = Header.tws_error :: t.recv_header in
     let result =
     -> Connection.t
     -> 'query
     -> 'response Or_error.t Deferred.t
-
-  val dispatch_exn
-    :  ('query, 'response) t
-    -> Connection.t
-    -> 'query
-    -> 'response Deferred.t
 end
 
 module Streaming_request : sig
     -> 'query
     -> ('response Pipe.Reader.t * Id.t) Or_error.t Deferred.t
 
-  val dispatch_exn
-    :  ('query, 'response) t
-    -> Connection.t
-    -> 'query
-    -> ('response Pipe.Reader.t * Id.t) Deferred.t
-
   (** [cancel req con id] cancels the TWS data stream from the request
       associated with the unique identifier [id], which was returned
       as part of a call to [dispatch]. *)