graph: Rename spawn_blocking_ignore_panic

Author: leoyvens

chain/ethereum/tests/network_indexer.rs

@@ -76,7 +76,7 @@ fn run_network_indexer(
     let (event_sink, event_stream) = futures::sync::mpsc::channel(100);
 
     // Run network indexer and forward its events to the channel
-    tokio::spawn(
+    graph::spawn(
         indexer
             .take_event_stream()
             .expect("failed to take stream from indexer")

graph/src/lib.rs

@@ -21,7 +21,7 @@ pub mod mock {
 
 /// Wrapper for spawning tasks that abort on panic, which is our default.
 mod task_spawn;
-pub use task_spawn::{spawn, spawn_blocking, spawn_blocking_ignore_panic};
+pub use task_spawn::{spawn, spawn_blocking, spawn_blocking_allow_panic};
 
 /// A prelude that makes all system component traits and data types available.
 ///

graph/src/task_spawn.rs

@@ -24,7 +24,7 @@ pub fn spawn_blocking<T: Send + 'static>(
     tokio::task::spawn_blocking(move || block_on(abort_on_panic(f)))
 }
 
-pub fn spawn_blocking_ignore_panic<T: Send + 'static>(
+pub fn spawn_blocking_allow_panic<T: Send + 'static>(
     f: impl Future03<Output = T> + Send + 'static,
 ) -> JoinHandle<T> {
     tokio::task::spawn_blocking(move || block_on(f))

runtime/wasm/src/host_exports.rs

@@ -680,5 +680,5 @@ fn test_string_to_h160_with_0x() {
 fn block_on<I: Send + 'static, ER: Send + 'static>(
     future: impl Future<Item = I, Error = ER> + Send + 'static,
 ) -> Result<I, ER> {
-    tokio::spawn(future.compat()).compat().wait().unwrap()
+    graph::spawn_blocking_allow_panic(future.compat()).compat().wait().unwrap()
 }

server/websocket/Cargo.toml

@@ -17,4 +17,4 @@ uuid = { version = "0.7.2", features = ["v4"] }
 
 # Needed for compatibility with tokio-tungstenite
 tokio01 = { version = "0.1.7", package = "tokio" }
-tokio-io = "0.1.7"
+tokio-io = "0.1.7"

server/websocket/src/server.rs

@@ -190,7 +190,7 @@ where
                                 ws_stream,
                                 graphql_runner.clone(),
                             );
-                            graph::spawn_blocking_ignore_panic(service.into_future().compat());
+                            graph::spawn_blocking_allow_panic(service.into_future().compat());
                         }
                         Err(e) => {
                             // We gracefully skip over failed connection attempts rather