summaryrefslogtreecommitdiff
path: root/ext/http/http_next.rs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2023-09-25 00:07:22 +0200
committerGitHub <noreply@github.com>2023-09-24 22:07:22 +0000
commitb2abae477115dc6ca97a767c6800c7c3f1aa0ebb (patch)
tree30efc8654c21ebeb65cc3e60b14b336506ca42ad /ext/http/http_next.rs
parent98ef7bd8183f7fa534c3bfea8376d4c452b5d8d7 (diff)
refactor: rewrite more ops to op2 (#20666)
Diffstat (limited to 'ext/http/http_next.rs')
-rw-r--r--ext/http/http_next.rs11
1 files changed, 5 insertions, 6 deletions
diff --git a/ext/http/http_next.rs b/ext/http/http_next.rs
index 08d3f54b1..21e138f86 100644
--- a/ext/http/http_next.rs
+++ b/ext/http/http_next.rs
@@ -23,7 +23,6 @@ use crate::LocalExecutor;
use cache_control::CacheControl;
use deno_core::error::AnyError;
use deno_core::futures::TryFutureExt;
-use deno_core::op;
use deno_core::op2;
use deno_core::serde_v8::from_v8;
use deno_core::unsync::spawn;
@@ -1264,13 +1263,13 @@ pub fn op_can_write_vectored(
state.resource_table.get::<UpgradeStream>(rid).is_ok()
}
-// TODO(bartlomieju): op2 doesn't want to handle `usize` in the return type
-#[op]
+#[op2(async)]
+#[number]
pub async fn op_raw_write_vectored(
state: Rc<RefCell<OpState>>,
- rid: ResourceId,
- buf1: JsBuffer,
- buf2: JsBuffer,
+ #[smi] rid: ResourceId,
+ #[buffer] buf1: JsBuffer,
+ #[buffer] buf2: JsBuffer,
) -> Result<usize, AnyError> {
let resource: Rc<UpgradeStream> =
state.borrow().resource_table.get::<UpgradeStream>(rid)?;