in crates/libs/core/src/client/query_client.rs [99:114]
fn get_partition_load_information_internal(
&self,
desc: &FABRIC_PARTITION_LOAD_INFORMATION_QUERY_DESCRIPTION,
timeout_milliseconds: u32,
cancellation_token: Option<CancellationToken>,
) -> FabricReceiver<crate::WinResult<IFabricGetPartitionLoadInformationResult>> {
let com1 = &self.com;
let com2 = self.com.clone();
fabric_begin_end_proxy(
move |callback| unsafe {
com1.BeginGetPartitionLoadInformation(desc, timeout_milliseconds, callback)
},
move |ctx| unsafe { com2.EndGetPartitionLoadInformation(ctx) },
cancellation_token,
)
}