in crates/libs/core/src/client/query_client.rs [82:97]
fn get_replica_list_internal(
&self,
desc: &FABRIC_SERVICE_REPLICA_QUERY_DESCRIPTION,
timeout_milliseconds: u32,
cancellation_token: Option<CancellationToken>,
) -> FabricReceiver<crate::WinResult<IFabricGetReplicaListResult2>> {
let com1 = &self.com;
let com2 = self.com.clone();
fabric_begin_end_proxy(
move |callback| unsafe {
com1.BeginGetReplicaList(desc, timeout_milliseconds, callback)
},
move |ctx| unsafe { com2.EndGetReplicaList2(ctx) },
cancellation_token,
)
}