Function receive_through_current_until 

pub async fn receive_through_current_until<C: XmtpSharedContext>(
    context: &C,
    topics: Vec<Topic>,
    deadline: Instant,
) -> Result<BarrierSnapshot, BarrierError>

Target sampling and processing use one deadline.