in crates/libs/core/src/client/svc_mgmt_client.rs [115:130]
fn register_service_notification_filter_internal(
&self,
desc: &FABRIC_SERVICE_NOTIFICATION_FILTER_DESCRIPTION,
timeout_milliseconds: u32,
cancellation_token: Option<CancellationToken>,
) -> FabricReceiver<crate::WinResult<i64>> {
let com1 = &self.com;
let com2 = self.com.clone();
fabric_begin_end_proxy(
move |callback| unsafe {
com1.BeginRegisterServiceNotificationFilter(desc, timeout_milliseconds, callback)
},
move |ctx| unsafe { com2.EndRegisterServiceNotificationFilter(ctx) },
cancellation_token,
)
}