Rust: Fix worker error handling

Properly retrieve the error reason.
versatica · Oct 23, 2023 · 6e1684c · 6e1684c
1 parent bf99b96
commit 6e1684c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/rust/src/worker/channel.rs b/rust/src/worker/channel.rs
@@ -270,9 +270,9 @@ impl Channel {
                             .remove(&response.id().unwrap());
                         if let Some(mut sender) = sender {
                             // Request did not succeed.
-                            if let Ok(Some(error)) = response.error() {
+                            if let Ok(Some(reason)) = response.reason() {
                                 let _ = sender.send(Err(ResponseError {
-                                    reason: error.to_string(),
+                                    reason: reason.to_string(),
                                 }));
                             }
                             // Request succeeded.

diff --git a/rust/tests/integration/pipe_transport.rs b/rust/tests/integration/pipe_transport.rs
@@ -561,7 +561,6 @@ fn pipe_to_router_succeeds_with_video() {
 }
 
 #[test]
-#[ignore]
 fn pipe_to_router_fails_if_both_routers_belong_to_the_same_worker() {
     future::block_on(async move {
         let (worker1, _worker2, router1, _router2, transport1, _transport2) = init().await;
@@ -945,7 +944,6 @@ fn consume_for_pipe_producer_succeeds() {
 }
 
 #[test]
-#[ignore]
 fn producer_pause_resume_are_transmitted_to_pipe_consumer() {
     future::block_on(async move {
         let (_worker1, _worker2, router1, router2, transport1, transport2) = init().await;