iroh_blobs::provider

Function handle_observe

Source 
pub async fn handle_observe<H: ErrorHandler<W = IrohStreamWriter>>(
    pair: StreamPair<H::R, H::W>,
    store: Store,
    request: ObserveRequest,
) -> Result<()>