Struct re_protos::sdk_comms::v0::message_proxy_server::MessageProxyServer

pub struct MessageProxyServer<T> {
    inner: Arc<T>,
    accept_compression_encodings: EnabledCompressionEncodings,
    send_compression_encodings: EnabledCompressionEncodings,
    max_decoding_message_size: Option<usize>,
    max_encoding_message_size: Option<usize>,
}

Simple buffer for messages between SDKs and viewers.

• SDKs produce messages by calling WriteMessages
• Viewers consume messages by calling ReadMessages

The buffer is bounded by a memory limit, and will drop the oldest messages when the limit is reached.

Whenever ReadMessages is called, all buffered messages are sent in the order they were received. The stream will then also yield any new messages passed to WriteMessages from any client.

Fields

inner: Arc<T>

accept_compression_encodings: EnabledCompressionEncodings

send_compression_encodings: EnabledCompressionEncodings

max_decoding_message_size: Option<usize>

max_encoding_message_size: Option<usize>

Implementations

impl<T> MessageProxyServer<T>

pub fn new(inner: T) -> Self

pub fn from_arc(inner: Arc<T>) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> InterceptedService<Self, F>

where F: Interceptor,

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing requests with the given encoding.

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress responses with the given encoding, if the client supports it.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations

impl<T> Clone for MessageProxyServer<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for MessageProxyServer<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> NamedService for MessageProxyServer<T>

const NAME: &'static str = SERVICE_NAME

The Service-Name as described here.

impl<T, B> Service<Request<B>> for MessageProxyServer<T>

where T: MessageProxy, B: Body + Send + 'static, B::Error: Into<StdError> + Send + 'static,

type Response = Response<UnsyncBoxBody<Bytes, Status>>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<MessageProxyServer<T> as Service<Request<B>>>::Response, <MessageProxyServer<T> as Service<Request<B>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Request<B>) -> Self::Future

Process the request and return the response asynchronously.