in crates/libs/core/src/sync/bridge_context.rs [133:144]
fn consume_content(&self) -> crate::Result<T> {
match self.check_complete() {
true => self.content.take().expect("content is consumed twice."),
false => {
if self.token.is_cancelled() {
Err(ErrorCode::E_ABORT.into())
} else {
Err(ErrorCode::FABRIC_E_OPERATION_NOT_COMPLETE.into())
}
}
}
}