pub trait FetchResponseConfig: 'static + Clone + Send + Sync {
type User: 'static + Send;
// Required method
fn respond(
&self,
space: Arc<KitsuneSpace>,
user: Self::User,
completion_guard: FetchResponseGuard,
op: Arc<KitsuneOpData>
);
// Provided methods
fn byte_limit(&self) -> u32 { ... }
fn concurrent_send_limit(&self) -> u32 { ... }
}
Expand description
Customization by code making use of the FetchResponseQueue.
Required Associated Types§
Required Methods§
sourcefn respond(
&self,
space: Arc<KitsuneSpace>,
user: Self::User,
completion_guard: FetchResponseGuard,
op: Arc<KitsuneOpData>
)
fn respond( &self, space: Arc<KitsuneSpace>, user: Self::User, completion_guard: FetchResponseGuard, op: Arc<KitsuneOpData> )
Send this fetch response.
Provided Methods§
sourcefn byte_limit(&self) -> u32
fn byte_limit(&self) -> u32
Byte count allowed to be outstanding. Any ops requested to be enqueued over this amount will be dropped without responding.
sourcefn concurrent_send_limit(&self) -> u32
fn concurrent_send_limit(&self) -> u32
Number of concurrent sends to allow.
Object Safety§
This trait is not object safe.