diff options
author | Aaron O'Mullan <aaron.omullan@gmail.com> | 2021-11-09 19:26:17 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-11-09 19:26:17 +0100 |
commit | 375ce63c6390cf7710210ce22f14a2b5a02cbfc3 (patch) | |
tree | 85100876e5e0b50514385ae3c7ce08493c82b38b /ext/net/01_net.js | |
parent | 1eae6c139ee1dac28df57d67d993792b773fa1ff (diff) |
feat(core): streams (#12596)
This allows resources to be "streams" by implementing read/write/shutdown. These streams are implicit since their nature (read/write/duplex) isn't known until called, but we could easily add another method to explicitly tag resources as streams.
`op_read/op_write/op_shutdown` are now builtin ops provided by `deno_core`
Note: this current implementation is simple & straightforward but it results in an additional alloc per read/write call
Closes #12556
Diffstat (limited to 'ext/net/01_net.js')
-rw-r--r-- | ext/net/01_net.js | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ext/net/01_net.js b/ext/net/01_net.js index fa38c8952..0afdbeebc 100644 --- a/ext/net/01_net.js +++ b/ext/net/01_net.js @@ -18,16 +18,16 @@ if (buffer.length === 0) { return 0; } - const nread = await core.opAsync("op_net_read_async", rid, buffer); + const nread = await core.read(rid, buffer); return nread === 0 ? null : nread; } async function write(rid, data) { - return await core.opAsync("op_net_write_async", rid, data); + return await core.write(rid, data); } function shutdown(rid) { - return core.opAsync("op_net_shutdown", rid); + return core.shutdown(rid); } function opAccept(rid, transport) { |