mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-14 12:51:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Inching closer

Browse Source
This commit is contained in:
Jarred Sumner
2024-02-09 04:12:41 -08:00
parent e0778944fe
commit 4cde96605a
3 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/bun.js/api/bun/subprocess.zig
View File

@@ -862,7 +862,7 @@ pub const Subprocess = struct {
switch (this.state) {
.pending => {
const stream = JSC.WebCore.ReadableStream.fromPipe(globalObject, &this.reader);
const stream = JSC.WebCore.ReadableStream.fromPipe(globalObject, this, &this.reader);
this.state = .{ .done = &.{} };
return stream;
},

6
src/bun.js/webcore/streams.zig
View File

@@ -360,6 +360,7 @@ pub const ReadableStream = struct {
pub fn fromPipe(
globalThis: *JSGlobalObject,
parent: anytype,
buffered_reader: anytype,
) JSC.JSValue {
JSC.markBinding(@src());
@@ -371,6 +372,11 @@ pub const ReadableStream = struct {
});
source.context.reader.from(buffered_reader, &source.context);
if (comptime Environment.isPosix) {
source.context.fd = parent.fd;
parent.fd = bun.invalid_fd;
}
return source.toJS(globalThis);
}

3
src/io/PipeReader.zig
View File

@@ -544,7 +544,8 @@ const PosixBufferedReader = struct {
pub fn registerPoll(this: *PosixBufferedReader) void {
const poll = this.handle.getPoll() orelse brk: {
if (this.handle == .fd and this.pollable) {
break :brk Async.FilePoll.init(this.eventLoop(), this.getFd(), .{}, @This(), this);
this.handle = .{ .poll = Async.FilePoll.init(this.eventLoop(), this.getFd(), .{}, @This(), this) };
break :brk this.handle.poll;
}
return;