re_grpc_client/message_proxy/
write_table.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
use re_protos::sdk_comms::v1alpha1::message_proxy_service_client::MessageProxyServiceClient;

#[cfg(not(target_arch = "wasm32"))]
pub type ViewerClient = MessageProxyServiceClient<tonic::transport::Channel>;

#[cfg(not(target_arch = "wasm32"))]
pub async fn viewer_client(
    origin: re_uri::Origin,
) -> Result<ViewerClient, crate::redap::ConnectionError> {
    let channel = crate::redap::channel(origin).await?;
    Ok(MessageProxyServiceClient::new(channel)
        .max_decoding_message_size(crate::MAX_DECODING_MESSAGE_SIZE))
}