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 /cli/tests/unit/metrics_test.ts | |
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 'cli/tests/unit/metrics_test.ts')
-rw-r--r-- | cli/tests/unit/metrics_test.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cli/tests/unit/metrics_test.ts b/cli/tests/unit/metrics_test.ts index 70efeac21..f020d69e8 100644 --- a/cli/tests/unit/metrics_test.ts +++ b/cli/tests/unit/metrics_test.ts @@ -16,7 +16,7 @@ unitTest(async function metrics() { assert(m1.bytesSentControl === 0); assert(m1.bytesSentData === 0); assert(m1.bytesReceived === 0); - const m1OpWrite = m1.ops["op_write_async"]; + const m1OpWrite = m1.ops["op_write"]; assert(m1OpWrite.opsDispatchedAsync > 0); assert(m1OpWrite.opsCompletedAsync > 0); assert(m1OpWrite.bytesSentControl === 0); @@ -31,7 +31,7 @@ unitTest(async function metrics() { assert(m2.bytesSentControl === m1.bytesSentControl); assert(m2.bytesSentData === 0); assert(m2.bytesReceived === m1.bytesReceived); - const m2OpWrite = m2.ops["op_write_async"]; + const m2OpWrite = m2.ops["op_write"]; assert(m2OpWrite.opsDispatchedAsync > m1OpWrite.opsDispatchedAsync); assert(m2OpWrite.opsCompletedAsync > m1OpWrite.opsCompletedAsync); assert(m2OpWrite.bytesSentControl === m1OpWrite.bytesSentControl); |