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

pub trait FetchResponseConfig: 'static + Send + Sync {
    type User: 'static + Send;

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

    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