summaryrefslogtreecommitdiff
path: root/test_plugin/src/lib.rs
diff options
context:
space:
mode:
authorAaron O'Mullan <aaron.omullan@gmail.com>2021-04-02 15:47:57 +0200
committerGitHub <noreply@github.com>2021-04-02 09:47:57 -0400
commit058579da562989ed15c86598053644bbc86c6747 (patch)
tree7f0f2bf30684dcbb350b93d987771f17a4abd250 /test_plugin/src/lib.rs
parentadf57610904cb4f4ef25fb077f6e39c9017a4ea9 (diff)
refactor(ops): remove variadic buffers (#9944)
Diffstat (limited to 'test_plugin/src/lib.rs')
-rw-r--r--test_plugin/src/lib.rs18
1 files changed, 8 insertions, 10 deletions
diff --git a/test_plugin/src/lib.rs b/test_plugin/src/lib.rs
index c4b0916a4..b84dcef48 100644
--- a/test_plugin/src/lib.rs
+++ b/test_plugin/src/lib.rs
@@ -14,15 +14,14 @@ pub fn deno_plugin_init(interface: &mut dyn Interface) {
fn op_test_sync(
_interface: &mut dyn Interface,
- zero_copy: &mut [ZeroCopyBuf],
+ zero_copy: Option<ZeroCopyBuf>,
) -> Op {
- if !zero_copy.is_empty() {
+ if zero_copy.is_some() {
println!("Hello from plugin.");
}
- let zero_copy = zero_copy.to_vec();
- for (idx, buf) in zero_copy.iter().enumerate() {
+ if let Some(buf) = zero_copy {
let buf_str = std::str::from_utf8(&buf[..]).unwrap();
- println!("zero_copy[{}]: {}", idx, buf_str);
+ println!("zero_copy: {}", buf_str);
}
let result = b"test";
let result_box: Box<[u8]> = Box::new(*result);
@@ -31,16 +30,15 @@ fn op_test_sync(
fn op_test_async(
_interface: &mut dyn Interface,
- zero_copy: &mut [ZeroCopyBuf],
+ zero_copy: Option<ZeroCopyBuf>,
) -> Op {
- if !zero_copy.is_empty() {
+ if zero_copy.is_some() {
println!("Hello from plugin.");
}
- let zero_copy = zero_copy.to_vec();
let fut = async move {
- for (idx, buf) in zero_copy.iter().enumerate() {
+ if let Some(buf) = zero_copy {
let buf_str = std::str::from_utf8(&buf[..]).unwrap();
- println!("zero_copy[{}]: {}", idx, buf_str);
+ println!("zero_copy: {}", buf_str);
}
let (tx, rx) = futures::channel::oneshot::channel::<Result<(), ()>>();
std::thread::spawn(move || {