in crates/libs/core/src/runtime/stateless_bridge.rs [130:146]
fn BeginOpen(
&self,
partition: windows_core::Ref<IFabricStatelessServicePartition>,
callback: windows_core::Ref<super::IFabricAsyncOperationCallback>,
) -> crate::WinResult<super::IFabricAsyncOperationContext> {
let partition_cp = partition.unwrap().clone();
let partition_bridge = StatelessServicePartition::new(partition_cp);
let inner = self.inner.clone();
let (ctx, token) = BridgeContext::make(callback);
ctx.spawn(&self.rt, async move {
inner
.open(&partition_bridge, token)
.await
.map(|s| IFabricStringResult::from(WStringWrap::from(s)))
.map_err(crate::WinError::from)
})
}