in crates/libs/core/src/runtime/stateful_bridge.rs [483:497]
fn BeginWaitForCatchUpQuorum(
&self,
catchupmode: FABRIC_REPLICA_SET_QUORUM_MODE,
callback: windows_core::Ref<super::IFabricAsyncOperationCallback>,
) -> crate::WinResult<super::IFabricAsyncOperationContext> {
let catchupmode = catchupmode.into();
let inner = self.inner.clone();
let (ctx, token) = BridgeContext::make(callback);
ctx.spawn(&self.rt, async move {
inner
.wait_for_catch_up_quorum(catchupmode, token)
.await
.map_err(crate::WinError::from)
})
}