diff options
author | 2022-11-15 17:52:04 -0800 | |
---|---|---|
committer | 2022-11-15 17:52:04 -0800 | |
commit | 934360646fd063a84c6527eea059dc40ae0050bb (patch) | |
tree | 41d17932e07fd3230ab924b102079d84ee0403e3 /src/bun.js/webcore/streams.zig | |
parent | 98df9d7703708cc7351563b9500d6a337003c3eb (diff) | |
download | bun-u/vjpr/zig-0.10.tar.gz bun-u/vjpr/zig-0.10.tar.zst bun-u/vjpr/zig-0.10.zip |
Diffstat (limited to 'src/bun.js/webcore/streams.zig')
-rw-r--r-- | src/bun.js/webcore/streams.zig | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/src/bun.js/webcore/streams.zig b/src/bun.js/webcore/streams.zig index 6d4fcb6bf..49e214bb7 100644 --- a/src/bun.js/webcore/streams.zig +++ b/src/bun.js/webcore/streams.zig @@ -3162,6 +3162,7 @@ pub const FileBlobLoader = struct { resume this.concurrent.read_frame; } + const ScheduleReadFrame = @Frame(scheduleRead); pub fn scheduleRead(this: *FileBlobLoader) void { if (comptime Environment.isMac) { var remaining = this.buf[this.concurrent.read..]; @@ -3209,14 +3210,15 @@ pub const FileBlobLoader = struct { null, ); - suspend { - var _frame = @frame(); - var this_frame = bun.default_allocator.create(std.meta.Child(@TypeOf(_frame))) catch unreachable; - this_frame.* = _frame.*; - this.concurrent.read_frame = this_frame; - } + // suspend { + // var _frame = @frame(); + // var this_frame = bun.allocateFrame(ScheduleReadFrame) catch unreachable; + // this_frame.* = _frame.*; + // this.concurrent.read_frame = this_frame; + // } + unreachable; - scheduleMainThreadTask(this); + // scheduleMainThreadTask(this); } pub fn onJSThread(task_ctx: *anyopaque) void { |