Skip to content

objects/uts: pin the sync-wait ordering with process_pending_events() #519

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sacOO7 merged 1 commit into from
Aug 28, 2026
Merged

objects/uts: pin the sync-wait ordering with process_pending_events() #519

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions uts/objects/unit/realtime_object.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -217,6 +217,9 @@ mock_ws.send_to_client(ProtocolMessage(

get_future = channel.object.get()

# Let get() park in the RTO23c sync wait before the channel-state change (see process_pending_events in uts/README.md)
process_pending_events()

# While still SYNCING the get() cannot complete — it parks in the RTO23c wait for SYNCED
ASSERT get_future IS NOT complete

Expand Down Expand Up @@ -262,6 +265,9 @@ mock_ws.send_to_client(ProtocolMessage(
))

get_future = channel.object.get()

# Let get() park in the RTO23c sync wait before the channel-state change (see process_pending_events in uts/README.md)
process_pending_events()
ASSERT get_future IS NOT complete

# The mock cannot drive SUSPENDED; drive the channel-state handler directly (as RTO27 does)
Expand Down Expand Up @@ -304,6 +310,9 @@ mock_ws.send_to_client(ProtocolMessage(
))

get_future = channel.object.get()

# Let get() park in the RTO23c sync wait before the channel-state change (see process_pending_events in uts/README.md)
process_pending_events()
ASSERT get_future IS NOT complete

# A channel ERROR moves the channel to FAILED and sets its errorReason
Expand Down Expand Up @@ -677,6 +686,9 @@ inc_future = root.get("score").increment(10)

# The publish and its ACK complete against the mock; publishAndApply parks in the
# RTO20e wait for SYNCED

# Let it settle in the RTO20e wait before the channel-state change (see process_pending_events in uts/README.md)
process_pending_events()
ASSERT inc_future IS NOT complete

# A client-side detach then moves the channel to DETACHED
Expand Down Expand Up @@ -720,6 +732,9 @@ inc_future = root.get("score").increment(10)

# The publish and its ACK complete against the mock; publishAndApply parks in the
# RTO20e wait for SYNCED

# Let it settle in the RTO20e wait before the channel-state change (see process_pending_events in uts/README.md)
process_pending_events()
ASSERT inc_future IS NOT complete

# Then the channel ERROR moves the channel to FAILED
Expand Down
Loading