From cf542922e890bfa3533df1cd587e169f2bba08d9 Mon Sep 17 00:00:00 2001 From: DoTheBestToGetTheBest <146037313+DoTheBestToGetTheBest@users.noreply.github.com> Date: Sun, 12 Nov 2023 06:00:19 -0800 Subject: [PATCH] feat(rpc-testing-utils) : test blocks for trace_call_stream method (#5405) --- crates/rpc/rpc-testing-util/src/trace.rs | 33 ++++++++++++++++++++++++ 1 file changed, 33 insertions(+) diff --git a/crates/rpc/rpc-testing-util/src/trace.rs b/crates/rpc/rpc-testing-util/src/trace.rs index f935945c2f..3b4e28c2c5 100644 --- a/crates/rpc/rpc-testing-util/src/trace.rs +++ b/crates/rpc/rpc-testing-util/src/trace.rs @@ -602,4 +602,37 @@ mod tests { } } } + + #[tokio::test] + #[ignore] + async fn can_create_trace_call_stream() { + let client = HttpClientBuilder::default().build("http://localhost:8545").unwrap(); + + let trace_call_request = TraceCallRequest::default(); + + let mut stream = client.trace_call_stream(trace_call_request); + let mut successes = 0; + let mut failures = 0; + let mut all_results = Vec::new(); + + assert_is_stream(&stream); + + while let Some(result) = stream.next().await { + match result { + Ok(trace_result) => { + println!("Success: {:?}", trace_result); + successes += 1; + all_results.push(Ok(trace_result)); + } + Err((error, request)) => { + println!("Error for request {:?}: {:?}", request, error); + failures += 1; + all_results.push(Err((error, request))); + } + } + } + + println!("Total successes: {}", successes); + println!("Total failures: {}", failures); + } }