From 4d2b9cd37af2b9d6a145a04fc93117922e43df3a Mon Sep 17 00:00:00 2001 From: Ryan Dahl Date: Sat, 18 Apr 2020 20:05:13 -0400 Subject: Fix Op definitions (#4814) --- test_plugin/src/lib.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'test_plugin') 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) -> CoreOp { +pub fn op_test_sync(data: &[u8], zero_copy: Option) -> 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) -> CoreOp { Op::Sync(result_box) } -pub fn op_test_async(data: &[u8], zero_copy: Option) -> CoreOp { +pub fn op_test_async(data: &[u8], zero_copy: Option) -> 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) -> 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()) -- cgit v1.2.3