Struct Callback Message Limit Service

Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-pii-redaction -p nemo-relay-ffi -p nemo-relay-types -p nemo-relay-plugin -p nemo-relay-worker-proto -p nemo-relay-worker.

pub struct CallbackMessageLimitService<S> { /* private fields */ }

Select a generated tonic server’s codec limits before decoding each RPC body.

Implementations

`impl<S> CallbackMessageLimitService<S>`

impl<S> CallbackMessageLimitService<S>

`new`

pub fn new(
    inner: S,
    limits: WorkerCallbackMessageLimits,
    configure: fn(S, usize) -> S,
) -> Self

Wrap a generated tonic server with its send/receive configuration function.

Trait Implementations

`impl<S: Clone> Clone for CallbackMessageLimitService<S>`

impl<S: Clone> Clone for CallbackMessageLimitService<S>

`clone`

fn clone(&self) -> CallbackMessageLimitService<S>

`clone_from`

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

`impl<S: NamedService> NamedService for CallbackMessageLimitService<S>`

impl<S: NamedService> NamedService for CallbackMessageLimitService<S>

`NAME`

const NAME: &'static str = S::NAME

`impl<S, B> Service<Request<B>> for CallbackMessageLimitService<S>where S: Service<Request<B>> + Clone + NamedService,`

impl<S, B> Service<Request<B>> for CallbackMessageLimitService<S>where
    S: Service<Request<B>> + Clone + NamedService,

`Response`

type Response = <S as Service<Request<B>>>::Response

`Error`

type Error = <S as Service<Request<B>>>::Error

`Future`

type Future = <S as Service<Request<B>>>::Future

`poll_ready`

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

`call`

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