mirror of
https://github.com/oven-sh/bun
synced 2026-02-13 12:29:07 +00:00
1779ee807c
### What does this PR do? Allow upgrade to websockets using fetch This will avoid hanging in http.request and is a step necessary to implement the upgrade event in the node:http client. Changes in node:http need to be made in another PR to support 'upgrade' event (see https://github.com/oven-sh/bun/pull/22412) ### How did you verify your code works? Test --------- Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
35 lines
1.4 KiB
Zig
35 lines
1.4 KiB
Zig
const Signals = @This();
|
|
|
|
header_progress: ?*std.atomic.Value(bool) = null,
|
|
body_streaming: ?*std.atomic.Value(bool) = null,
|
|
aborted: ?*std.atomic.Value(bool) = null,
|
|
cert_errors: ?*std.atomic.Value(bool) = null,
|
|
upgraded: ?*std.atomic.Value(bool) = null,
|
|
pub fn isEmpty(this: *const Signals) bool {
|
|
return this.aborted == null and this.body_streaming == null and this.header_progress == null and this.cert_errors == null and this.upgraded == null;
|
|
}
|
|
|
|
pub const Store = struct {
|
|
header_progress: std.atomic.Value(bool) = std.atomic.Value(bool).init(false),
|
|
body_streaming: std.atomic.Value(bool) = std.atomic.Value(bool).init(false),
|
|
aborted: std.atomic.Value(bool) = std.atomic.Value(bool).init(false),
|
|
cert_errors: std.atomic.Value(bool) = std.atomic.Value(bool).init(false),
|
|
upgraded: std.atomic.Value(bool) = std.atomic.Value(bool).init(false),
|
|
pub fn to(this: *Store) Signals {
|
|
return .{
|
|
.header_progress = &this.header_progress,
|
|
.body_streaming = &this.body_streaming,
|
|
.aborted = &this.aborted,
|
|
.cert_errors = &this.cert_errors,
|
|
.upgraded = &this.upgraded,
|
|
};
|
|
}
|
|
};
|
|
|
|
pub fn get(this: Signals, comptime field: std.meta.FieldEnum(Signals)) bool {
|
|
var ptr: *std.atomic.Value(bool) = @field(this, @tagName(field)) orelse return false;
|
|
return ptr.load(.monotonic);
|
|
}
|
|
|
|
const std = @import("std");
|