Struct FoldQueryHandler 

pub struct FoldQueryHandler { /* private fields */ }

RpcHandler implementation that answers fold.query requests from a hosted AggregatorDaemon. Construct via AggregatorDaemon::query_handler and pass to crate::adapter::net::MeshNode::serve_rpc under FOLD_QUERY_SERVICE.

Implementations

impl FoldQueryHandler

pub fn new(aggregator: Arc<AggregatorDaemon>) -> Self

Wrap an aggregator daemon as an RPC handler.

Trait Implementations

impl RpcHandler for FoldQueryHandler

fn call<'life0, 'async_trait>( &'life0 self, ctx: RpcContext, ) -> Pin<Box<dyn Future<Output = Result<RpcResponsePayload, RpcHandlerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process one request and return the response payload. The fold spawns this in a tokio task; the fold itself doesn’t block on it. Handlers should respect ctx.cancellation for cooperative early-abort.