in crates/libs/core/src/client/svc_mgmt_client.rs [153:168]
fn create_service_internal(
&self,
desc: &FABRIC_SERVICE_DESCRIPTION,
timeout_milliseconds: u32,
cancellation_token: Option<CancellationToken>,
) -> FabricReceiver<crate::WinResult<()>> {
let com1 = &self.com;
let com2 = self.com.clone();
fabric_begin_end_proxy(
move |callback| unsafe {
com1.BeginCreateService(desc, timeout_milliseconds, callback)
},
move |ctx| unsafe { com2.EndCreateService(ctx) },
cancellation_token,
)
}