Vitor PamplonaandClaude Opus 5 5136a97b16 Return the walk's outcome instead of signalling a drain by callback ...

`onDrained` was the wrong shape. It reported the one ending a coverage
caller happens to need and threw the rest away, so a CLOSED and an idle
timeout still arrived indistinguishable from a clean finish — the very
conflation this branch set out to remove, just moved one step along.

`fetchAllPages` now returns `PagedFetchResult(downloaded, end)`, where
`end` names every way the loop can stop: DRAINED, LIMIT_REACHED, IDLE,
CLOSED, CANNOT_CONNECT, UNPAGEABLE. `drained` stays as a shorthand on the
result so the meaning lives in one place. A caller can no longer ignore
the reason by accident, and the two failure endings are now reportable
rather than silently swallowed.

I argued for the callback on the grounds that ~25 call sites use the
`Int`. That was overstated: most call it as a statement and never touch
the return. Six needed a `.downloaded`, all mechanical.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_016TNy5BsU9NErXYa3UNGTeJ

2026-08-09 05:25:06 +00:00

..

main/kotlin/com/vitorpamplona/geode

Return the walk's outcome instead of signalling a drain by callback

2026-08-09 05:25:06 +00:00

test/kotlin/com/vitorpamplona/geode

Merge pull request #3863 from vitorpamplona/feat/suspend-subscription-onevent

2026-08-05 14:35:03 -04:00

testFixtures/kotlin/com/vitorpamplona/geode

Suspend the incoming-message chain down to SubscriptionListener.onEvent

2026-08-05 12:45:02 -04:00