async fn do_read_filter_request(
    storage_client: &mut StorageClient<Connection>,
    request: ReadFilterRequest,
) -> Vec<String> {
    let request = tonic::Request::new(request);

    let read_filter_response = storage_client
        .read_filter(request)
        .await
        .expect("successful read_filter call");

    let responses: Vec<_> = read_filter_response
        .into_inner()
        .try_collect()
        .await
        .unwrap();

    let frames: Vec<_> = responses
        .into_iter()
        .flat_map(|r| r.frames)
        .flat_map(|f| f.data)
        .collect();

    dump_data_frames(&frames)
}
/// Make a read_group request and returns the results in a comparable format
Make a read_group request and returns the results in a comparable format
Make a read_group request and returns the results in a comparable format
async fn do_read_filter_request(
    storage_client: &mut StorageClient<Connection>,
    request: ReadFilterRequest,
) -> Vec<String> {
    let request = tonic::Request::new(request);
    let read_filter_response = storage_client
        .read_filter(request)
        .await
        .expect("successful read_filter call");
    let responses: Vec<_> = read_filter_response
        .into_inner()
        .try_collect()
        .await
        .unwrap();
    let frames: Vec<_> = responses
        .into_iter()
        .flat_map(|r| r.frames)
        .flat_map(|f| f.data)
        .collect();
    dump_data_frames(&frames)
}
async fn do_read_filter_request ( storage_client : & mut StorageClient < Connection > , request : ReadFilterRequest , ) -> Vec < String > { let request = tonic :: Request :: new ( request ) ; let read_filter_response = storage_client . read_filter ( request ) . await . expect ( " " ) ; let responses : Vec < _ > = read_filter_response . into_inner ( ) . try_collect ( ) . await . unwrap ( ) ; let frames : Vec < _ > = responses . into_iter ( ) . flat_map ( | r | r . frames ) . flat_map ( | f | f . data ) . collect ( ) ; dump_data_frames ( & frames ) }
Make a read_group request and returns the results in a comparable format
Make a read_group request and returns the results in a comparable format
storage_client
&mut StorageClient<Connection>
request
ReadFilterRequest
storage_client
&mut StorageClient<Connection>
request
ReadFilterRequest