Compare commits

..

1 commit

Author SHA1 Message Date
Stéphane Lavergne
3affd35312
Merge dab9ca8190 into 4b7d9ec769 2025-02-04 15:56:39 +00:00

View file

@ -148,16 +148,28 @@ let _apply_config (self : t) (config : Config.t) : unit =
let _eq_case a b =
let low = String.lowercase_ascii in
String.equal (low a) (low b)
String.compare (low a) (low b) = 0
let _add_header_nodup (h : string * string) (headers : _ list ref) : unit =
let sq = List.to_seq !headers in
let k, v = h in
if not (List.exists (fun (tk,tv) -> _eq_case k tk && _eq_case v tv) !headers) then
match
Seq.find_index
(fun t ->
let tk, tv = t in
_eq_case k tk && _eq_case v tv)
sq
with
| None ->
headers := h :: !headers;
()
| Some _ -> () (* No duplicate *)
let _contains_resp_headers (h : string) (headers : string list) : bool =
List.exists (_eq_case h) headers
let sq = List.to_seq headers in
match Seq.find_index (fun hh -> _eq_case h hh) sq with
| None -> false
| Some _ -> true
let _set_headers (self : t) (headers : _ list) : unit =
let headers = List.map (fun (k, v) -> k ^ ": " ^ v) headers in
@ -386,8 +398,11 @@ let mk_res (self : t) headers body : (_ response, _) result =
let sse_frame_with_event sse_f v =
{
(!sse_f) with
event = Some v;
id = !sse_f.id;
data = !sse_f.data;
retry = !sse_f.retry;
empties = !sse_f.empties;
}
let sse_frame_with_id sse_f v =