Complete the SharedFlow-typed session lanes on close: outboundSends, aggregationUpdates, verificationRequests, metrics (§8) #172

Open
opened 2026-09-01 13:21:44 +02:00 by thecrealm · 0 comments
Owner

Found while adding the #143 stream-completion test (D89). §8: close() completes all public streams. The Flow-typed lanes (events, accountDataEvents, ephemeralEvents, toDeviceEvents, pushSignals, typedEvents) now complete on the closed signal; the SharedFlow-typed publics cannot complete by type: KatrixSession.outboundSends, aggregationUpdates, verificationRequests, metrics (and the fleet's equivalents, if any). Acceptance: re-type them to Flow (pre-1.0, apiDump), run them through untilClosed(), extend DeviceManagementTest.closeCompletesTheLanes to every public lane; §8 unchanged.

Found while adding the #143 stream-completion test (D89). §8: close() completes all public streams. The Flow-typed lanes (events, accountDataEvents, ephemeralEvents, toDeviceEvents, pushSignals, typedEvents) now complete on the closed signal; the SharedFlow-typed publics cannot complete by type: KatrixSession.outboundSends, aggregationUpdates, verificationRequests, metrics (and the fleet's equivalents, if any). Acceptance: re-type them to Flow<T> (pre-1.0, apiDump), run them through untilClosed(), extend DeviceManagementTest.closeCompletesTheLanes to every public lane; §8 unchanged.
Sign in to join this conversation.
No milestone
No project
No assignees
1 participant
Notifications
Due date
The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference
thecrealm/katrix#172
No description provided.