Trait holochain::prelude::kitsune_p2p::dependencies::kitsune_p2p_fetch::FetchResponseConfig

pub trait FetchResponseConfig: 'static + 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 { ... }
}

Customization by code making use of the FetchResponseQueue.

Required Associated Types

type User: 'static + Send

Data that is forwarded.

Required Methods

fn respond( &self, space: Arc<KitsuneSpace>, user: Self::User, completion_guard: FetchResponseGuard, op: Arc<KitsuneOpData> )

Send this fetch response.

Provided Methods

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.

fn concurrent_send_limit(&self) -> u32

Number of concurrent sends to allow.

Implementors