Struct FetcherService 

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

Service layer that wraps FetcherState and manages subscriber coalescing.

When multiple callers request the same fetch, their subscribers are collected and all notified when the fetch completes.

Type Parameter

• S: The subscriber type (e.g., chan::Sender<FetchResult>).

Implementations

impl<S> FetcherService<S>

pub fn new(config: Config) -> Self

Initialize the FetcherService with the give Config.

pub fn state(&self) -> &FetcherState

Provide a reference handle to the FetcherState.

impl<S> FetcherService<S>

pub fn fetch(&mut self, cmd: Fetch, subscriber: Option<S>) -> FetchInitiated<S>

Initiate a fetch, optionally registering a subscriber.

Subscribers are coalesced: if the same (rid, node) is already being fetched or queued, the subscriber joins the existing waiters.

If the fetch could not be initiated, and also could not be queued, then subscriber is returned to notify of the rejection.

See FetcherState::fetch.

pub fn fetched(&mut self, cmd: Fetched) -> FetchCompleted<S>

Mark a fetch as completed and retrieve waiting subscribers.

See FetcherState::fetched.

pub fn cancel(&mut self, cmd: Cancel) -> FetchesCancelled<S>

Cancel all fetches for a disconnected peer, returning any orphaned subscribers.

See FetcherState::cancel.

pub fn dequeue(&mut self, from: &NodeId) -> Option<QueuedFetch>

Dequeue the next fetch for a node.

See FetcherState::dequeue.

Trait Implementations

impl<S: Debug> Debug for FetcherService<S>

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

Formats the value using the given formatter.