grpc-rs 0.0.2

Runtime-free gRPC client and server framework for Rust over nexora-proto HTTP/2 and Linux io_uring
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Integration contract for public error presentation and source traversal.
use std::error::Error;

use grpc::{Status, StreamError};

#[test]
fn integration_stream_error_preserves_status_source_and_display() -> anyhow::Result<()> {
    use anyhow::{Context, ensure};
    let error = StreamError::from(Status::invalid_argument("quantity must be positive"));
    ensure!(error.to_string() == "InvalidArgument: quantity must be positive");
    let source = error.source().context("stream error lost Status source")?;
    let source = source
        .downcast_ref::<Status>()
        .context("wrong source type")?;
    ensure!(source.code() == grpc::core::Code::InvalidArgument);
    ensure!(source.source().is_none());
    ensure!(StreamError::WouldBlock.to_string() == "stream would block");
    ensure!(StreamError::WouldBlock.source().is_none());
    Ok(())
}