GameCult/ModelConnector
Watch
9
0
Fork
You've already forked ModelConnector
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

connector-usage-only: test import

Browse source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-10-31 04:49:29 +01:00
commit 28f2e5d2e7
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
crates/model-connector/src/service.rs
View file

@ -2171,7 +2171,7 @@ mod tests {
service.begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME), service.begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME),
Err(ServiceError::ReplayStore(_)) Err(ServiceError::ReplayStore(_))
)); ));
allowance.store(10, Ordering::SeqCst); allowance.store(10, std::sync::atomic::Ordering::SeqCst);
assert!(matches!( assert!(matches!(
service.begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME), service.begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME),
Ok(TransportAdmission::Execute(_)) Ok(TransportAdmission::Execute(_))
@ -2193,7 +2193,7 @@ mod tests {
)); ));
// The slot is free (one concurrent request is admitted), and the retry // The slot is free (one concurrent request is admitted), and the retry
// of the unfinished id is told it is indeterminate, not in flight. // of the unfinished id is told it is indeterminate, not in flight.
allowance.store(10, Ordering::SeqCst); allowance.store(10, std::sync::atomic::Ordering::SeqCst);
let again = service let again = service
.begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME) .begin_unplanned(&raw_envelope(&invocation), 1_000, FRAME)
.unwrap(); .unwrap();