diff options
author | Ryan Dahl <ry@tinyclouds.org> | 2020-04-18 20:05:13 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-04-18 20:05:13 -0400 |
commit | 4d2b9cd37af2b9d6a145a04fc93117922e43df3a (patch) | |
tree | 72625816dd4dd2fabd34a74770f5b9c3a7b0554e /test_plugin/src/lib.rs | |
parent | e2fd729a0b26c299f0cc4e4618d1f97159b31a19 (diff) |
Fix Op definitions (#4814)
Diffstat (limited to 'test_plugin/src/lib.rs')
-rw-r--r-- | test_plugin/src/lib.rs | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/test_plugin/src/lib.rs b/test_plugin/src/lib.rs index 922f33682..70ba6d9b2 100644 --- a/test_plugin/src/lib.rs +++ b/test_plugin/src/lib.rs @@ -2,7 +2,6 @@ extern crate deno_core; extern crate futures; -use deno_core::CoreOp; use deno_core::Op; use deno_core::PluginInitContext; use deno_core::{Buf, ZeroCopyBuf}; @@ -14,7 +13,7 @@ fn init(context: &mut dyn PluginInitContext) { } init_fn!(init); -pub fn op_test_sync(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> CoreOp { +pub fn op_test_sync(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> Op { if let Some(buf) = zero_copy { let data_str = std::str::from_utf8(&data[..]).unwrap(); let buf_str = std::str::from_utf8(&buf[..]).unwrap(); @@ -28,7 +27,7 @@ pub fn op_test_sync(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> CoreOp { Op::Sync(result_box) } -pub fn op_test_async(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> CoreOp { +pub fn op_test_async(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> Op { let data_str = std::str::from_utf8(&data[..]).unwrap().to_string(); let fut = async move { if let Some(buf) = zero_copy { @@ -46,7 +45,7 @@ pub fn op_test_async(data: &[u8], zero_copy: Option<ZeroCopyBuf>) -> CoreOp { assert!(rx.await.is_ok()); let result = b"test"; let result_box: Buf = Box::new(*result); - Ok(result_box) + result_box }; Op::Async(fut.boxed()) |