mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-13 04:18:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip ReadableStream <> zig

Browse Source
This commit is contained in:
Jarred Sumner
2022-06-07 22:42:47 -07:00
parent 5b4dcb8d16
commit 609edc368f
1 changed files with 58 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
src/javascript/jsc/webcore/streams.zig
View File

@@ -48,12 +48,70 @@ const Response = JSC.WebCore.Response;
const Request = JSC.WebCore.Request;
pub const ReadableStream = struct {
value: JSValue,
ptr: Handle,
pub const Tag = enum(i32) {
Invalid = -1,
JavaScript = 0,
Blob = 1,
File = 2,
HTTPRequest = 3,
HTTPSRequest = 4,
};
pub const Handle = union(Tag) {
Invalid: void,
JavaScript: void,
Blob: *ByteBlobLoader,
File: *FileBlobLoader,
HTTPRequest: void,
HTTPSRequest: void,
};
extern fn ReadableStreamTag__tagged(globalObject: *JSGlobalObject, possibleReadableStream: JSValue, ptr: *JSValue) Tag;
extern fn ReadableStream__isDisturbed(possibleReadableStream: JSValue, globalObject: *JSGlobalObject) bool;
extern fn ReadableStream__isLocked(possibleReadableStream: JSValue, globalObject: *JSGlobalObject) bool;
extern fn ReadableStream__empty(*JSGlobalObject) JSC.JSValue;
extern fn ReadableStream__fromBlob(
*JSGlobalObject,
store: *anyopaque,
offset: usize,
length: usize,
) JSC.JSValue;
pub fn isDisturbed(this: *const ReadableStream, globalObject: *JSGlobalObject) bool {
return ReadableStream__isDisturbed(this.value, globalObject);
}
pub fn isLocked(this: *const ReadableStream, globalObject: *JSGlobalObject) bool {
return ReadableStream__isLocked(this.value, globalObject);
}
pub fn fromJS(value: JSValue, globalThis: *JSGlobalObject) ?ReadableStream {
var ptr = JSValue.zero;
return switch (ReadableStreamTag__tagged(globalThis, value, &ptr)) {
.JavaScript => ReadableStream{
.value = value,
.ptr = .{
.JavaScript = {},
},
},
.Blob => ReadableStream{
.value = value,
.ptr = .{
.Blob = ptr.asPtr(ByteBlobLoader),
},
},
.File => ReadableStream{
.value = value,
.ptr = .{
.File = ptr.asPtr(FileBlobLoader),
},
},
else => null,
};
}
extern fn ZigGlobalObject__createNativeReadableStream(*JSGlobalObject, nativePtr: JSValue, nativeType: JSValue) JSValue;
@@ -93,13 +151,6 @@ pub const ReadableStream = struct {
return ReadableStream__empty(globalThis);
}
extern fn ReadableStream__empty(*JSGlobalObject) JSC.JSValue;
extern fn ReadableStream__fromBlob(
*JSGlobalObject,
store: *anyopaque,
offset: usize,
length: usize,
) JSC.JSValue;
const Base = @import("../../../ast/base.zig");
pub const StreamTag = enum(usize) {
invalid = 0,