Summary
The stream manager should open a Horizon SSE connection per active payment subscription and
persist the paging cursor to SQLite so streams resume correctly after a restart.
Acceptance criteria
Notes
Use server.payments().forAccount(addr).cursor(saved).stream({ onmessage }).
Cursor must be saved per account key, not globally.
Summary
The stream manager should open a Horizon SSE connection per active
paymentsubscription andpersist the paging cursor to SQLite so streams resume correctly after a restart.
Acceptance criteria
StreamManager._streamPayments()opens an SSE stream via@stellar/stellar-sdkstream_cursorstable after each eventasset_codeandmin_amountapplied before queuing deliveryNotes
Use
server.payments().forAccount(addr).cursor(saved).stream({ onmessage }).Cursor must be saved per account key, not globally.