pub async fn wait_through<C: XmtpSharedContext>(
context: &C,
targets: TopicCursor,
timeout: Option<Duration>,
) -> Result<BarrierSnapshot, BarrierError>Expand description
Wait for all independent obligations before reporting blocked work. Prefer a healthy receiver for caller-supplied targets, with bounded Query fallback.