Update example to neon 0.9

EventQueue was deprecated since neon 0.9. And replace it with Channel.

Author: syohex

Cargo.lock

@@ -13,6 +13,6 @@ crate-type = ["cdylib"]
 rusqlite = "0.25"
 
 [dependencies.neon]
-version = "0.8"
+version = "0.9"
 default-features = false
 features = ["napi-6", "event-queue-api", "try-catch-api"]

examples/async-sqlite/Cargo.toml

@@ -37,7 +37,7 @@ Rust data cannot be directly held by JavaScript. The [`JsBox`][jsbox] provides a
 
 #### Channels and `EventQueue`
 
-The mpsc channel provides a way for the JavaScript main thread to communicate with the database thread, but it is one-way. In order to complete the callback, the database thread must be able to communicate with the JavaScript main thread. [`EventQueue`][eventqueue] provides a channel for sending these events back.
+The mpsc channel provides a way for the JavaScript main thread to communicate with the database thread, but it is one-way. In order to complete the callback, the database thread must be able to communicate with the JavaScript main thread. [`Channel`][channel] provides a channel for sending these events back.
 
 #### `Root`
 
@@ -49,7 +49,7 @@ A [`Root`][root] is a special handle to a JavaScript value that prevents the val
 
 [thread]: https://doc.rust-lang.org/std/thread/
 [mpsc]: https://doc.rust-lang.org/std/sync/mpsc/index.html
-[jsbox]: https://docs.rs/neon/0.8.1-napi/neon/types/struct.JsBox.html
-[eventqueue]: https://docs.rs/neon/0.8.1-napi/neon/event/struct.EventQueue.html
-[handle]: https://docs.rs/neon/0.8.1-napi/neon/handle/struct.Handle.html
-[root]: https://docs.rs/neon/0.8.1-napi/neon/handle/struct.Root.html
+[jsbox]: https://docs.rs/neon/0.9.1/neon/types/struct.JsBox.html
+[channel]: https://docs.rs/neon/0.9.1/neon/event/struct.Channel.html
+[handle]: https://docs.rs/neon/0.9.1/neon/handle/struct.Handle.html
+[root]: https://docs.rs/neon/0.9.1/neon/handle/struct.Root.html

examples/async-sqlite/README.md

@@ -4,7 +4,7 @@ use std::thread;
 use neon::prelude::*;
 use rusqlite::Connection;
 
-type DbCallback = Box<dyn FnOnce(&mut Connection, &EventQueue) + Send>;
+type DbCallback = Box<dyn FnOnce(&mut Connection, &Channel) + Send>;
 
 // Wraps a SQLite connection a channel, allowing concurrent access
 struct Database {
@@ -41,11 +41,11 @@ impl Database {
         // Open a connection sqlite, this will be moved to the thread
         let mut conn = Connection::open_in_memory()?;
 
-        // Create an `EventQueue` for calling back to JavaScript. It is more efficient
-        // to create a single queue and re-use it for all database callbacks.
-        // The JavaScript process will not exit as long as this queue has not been
+        // Create an `Channel` for calling back to JavaScript. It is more efficient
+        // to create a single channel and re-use it for all database callbacks.
+        // The JavaScript process will not exit as long as this channel has not been
         // dropped.
-        let queue = cx.queue();
+        let channel = cx.channel();
 
         // Create a table in the in-memory database
         // In production code, this would likely be handled somewhere else
@@ -70,10 +70,10 @@ impl Database {
             while let Ok(message) = rx.recv() {
                 match message {
                     DbMessage::Callback(f) => {
-                        // The connection and queue are owned by the thread, but _lent_ to
+                        // The connection and channel are owned by the thread, but _lent_ to
                         // the callback. The callback has exclusive access to the connection
                         // for the duration of the callback.
-                        f(&mut conn, &queue);
+                        f(&mut conn, &channel);
                     }
                     // Immediately close the connection, even if there are pending messages
                     DbMessage::Close => break,
@@ -92,7 +92,7 @@ impl Database {
 
     fn send(
         &self,
-        callback: impl FnOnce(&mut Connection, &EventQueue) + Send + 'static,
+        callback: impl FnOnce(&mut Connection, &Channel) + Send + 'static,
     ) -> Result<(), mpsc::SendError<DbMessage>> {
         self.tx.send(DbMessage::Callback(Box::new(callback)))
     }
@@ -136,15 +136,15 @@ impl Database {
         // Get the `this` value as a `JsBox<Database>`
         let db = cx.this().downcast_or_throw::<JsBox<Database>, _>(&mut cx)?;
 
-        db.send(move |conn, queue| {
+        db.send(move |conn, channel| {
             let result = conn
                 .execute(
                     "INSERT INTO person (name) VALUES (?)",
                     rusqlite::params![name],
                 )
                 .map(|_| conn.last_insert_rowid());
 
-            queue.send(move |mut cx| {
+            channel.send(move |mut cx| {
                 let callback = callback.into_inner(&mut cx);
                 let this = cx.undefined();
                 let args: Vec<Handle<JsValue>> = match result {
@@ -175,12 +175,12 @@ impl Database {
         // Get the `this` value as a `JsBox<Database>`
         let db = cx.this().downcast_or_throw::<JsBox<Database>, _>(&mut cx)?;
 
-        db.send(move |conn, queue| {
+        db.send(move |conn, channel| {
             let result: Result<String, _> = conn
                 .prepare("SELECT name FROM person WHERE id = ?")
                 .and_then(|mut stmt| stmt.query_row(rusqlite::params![id], |row| row.get(0)));
 
-            queue.send(move |mut cx| {
+            channel.send(move |mut cx| {
                 let callback = callback.into_inner(&mut cx);
                 let this = cx.undefined();
                 let args: Vec<Handle<JsValue>> = match result {

examples/async-sqlite/src/lib.rs

@@ -13,6 +13,6 @@ crate-type = ["cdylib"]
 num_cpus = "1"
 
 [dependencies.neon]
-version = "0.8"
+version = "0.9"
 default-features = false
 features = ["napi-6"]

examples/cpu-count/Cargo.toml

@@ -10,6 +10,6 @@ exclude = ["index.node"]
 crate-type = ["cdylib"]
 
 [dependencies.neon]
-version = "0.8"
+version = "0.9"
 default-features = false
 features = ["napi-6"]