Function pb_aggregate

integration_tests/grpc_tests/rust/interop/src/main.rs:759–779

Builds the aggregate protobuf response used by client-streaming RPCs.

(requests: &[GrpcPbRequest])

// Builds the aggregate protobuf response used by client-streaming RPCs.
fn pb_aggregate(requests: &[GrpcPbRequest]) -> GrpcPbResponse {
    GrpcPbResponse {
        id: format!(
            "client:{}",
            requests
                .iter()
                .map(|request| request.id.as_str())
                .collect::<Vec<_>>()
                .join("+")
        ),
        count: requests.iter().map(|request| request.count).sum(),
        payload: Some(grpc_pb_response::Payload::Text(format!(
            "client:{}",
            requests
                .iter()
                .map(|request| request.id.as_str())
                .collect::<Vec<_>>()
                .join("+")
        ))),
    }
}

async fn exercise_pb(channel: Channel) -> AnyResult<()> {
    let mut client = PbGrpcServiceClient::new(channel);